经典多线程Java实例 生产者与消费者

package
factory;

class
Producer extends
Thread
{

private
Factory sharedLocation;

public
Producer(
Factory shared)
{

super
(
"Producer"
)
;

sharedLocation =
shared;

}

public
void
run
(
)
{

for
(
int
count
=
1;
count
<
=
10;
count
+
+
)
{

try
{

Thread
.
sleep
(
(
int
)
(
Math
.
random
(
)
*
2000)
)
;

sharedLocation.
set
(
count
)
;

}
catch
(
InterruptedException
e)
{

e.
printStackTrace
(
)
;

}

}

System
.
out.
println
(
getName
(
)
+
" 生产结束"
)
;

}

}

package
factory;

public
class
Consumer extends
Thread
{

private
Factory sharedLocation;

public
Consumer(
Factory shared)
{

super
(
"Consumer"
)
;

sharedLocation =
shared;

}

public
void
run
(
)
{

int
sum
=
0;

for
(
int
count
=
1;
count
<
=
10;
count
+
+
)
{

try
{

Thread
.
sleep
(
(
int
)
(
Math
.
random
(
)
*
3000)
)
;

//消费商品

sum
+
=
sharedLocation.
get
(
)
;

}
catch
(
InterruptedException
e)
{

e.
printStackTrace
(
)
;

}

}

System
.
out.
println
(
getName
(
)
+
" 消费总数 "
+
sum
+
" 消费结束"
)
;

}

}

package
factory;

public
interface
Factory {

public
void
set
(
int
value
)
;

public
int
get
(
)
;

}

package
factory;

/**

* 注意get set两个方法使用同一把锁

*/

public
class
FactorySynchronizedImpl implements
Factory {

private
int
item
=
-
1;

private
int
sign
=
0;
// >0是是可以买 ==0是不能卖

private
static
final
int
maxSize =
3;
// 最大库存

public
synchronized
void
set
(
int
value
)
{

String
name
=
Thread
.
currentThread
(
)
.
getName
(
)
;

while
(
sign
>
=
maxSize)
{

try
{

displayState(
"产品 "
+
name
+
" 库存已满!等待..."
)
;

wait
(
)
;

}
catch
(
InterruptedException
e)
{

e.
printStackTrace
(
)
;

}

}

item
=
value
;

+
+
sign
;

displayState(
name
+
" 生产 "
+
item
)
;

// 唤醒同锁线程

notify
(
)
;

}

public
synchronized
int
get
(
)
{

String
name
=
Thread
.
currentThread
(
)
.
getName
(
)
;

while
(
sign
<
=
0)
{

try
{

displayState(
"无产品 "
+
name
+
" 等待"
)
;

wait
(
)
;

}
catch
(
InterruptedException
e)
{

e.
printStackTrace
(
)
;

}

}

-
-
sign
;

displayState(
name
+
" 买 "
+
item
)
;

// 唤醒同锁线程

notify
(
)
;

return
item
;

}

public
void
displayState(
String
operation
)
{

System
.
out.
println
(
"操作序号:"
+
item
+
"/t/t库存:"
+
sign
+
"/t"
+
operation
)
;

}

}

package
factory;

public
class
Test {

public
static
void
main(
String
args[
]
)
{

FactorySynchronizedImpl factory =
new
FactorySynchronizedImpl(
)
;

System
.
out.
println
(
)
;

factory.
displayState(
"初始化"
)
;

Producer p =
new
Producer(
factory)
;

Consumer c =
new
Consumer(
factory)
;

p.
start
(
)
;

c.
start
(
)
;

}

}