關于Java多線程實現(xiàn)生產者和消費者的問題

Java修煉館 2011-09-27

展開全文

在學習Java多線程并發(fā)編程的同時，自己寫了一個用wait()和notifyAll()實現(xiàn)的生產者消費者相互阻塞，保持同步的程序。
設置產品緩沖區(qū)上限為8，可生產者檢查counter計數器等于8的時候wait()并沒有讓多個生產者線程阻塞，而是繼續(xù)向下執(zhí)行，對此表示不解，還請諸位高手們給菜鳥弟弟我一個解答，感激不盡！

Java代碼

/*
* 這是一個與多線程有關的以生產者消費者問題為原型的Java程序源碼。
* 為了體驗notify和notifyAll方法，我嘗試開啟十個生產者和五個消費者線程，對大小為8的緩沖區(qū)進行操作，要做到緩沖區(qū)產品達到8的時候，生產者線程阻塞，直到消費者線程減少緩沖區(qū)的產品數量，并對阻塞進程進行喚醒。
* 可現(xiàn)在的問題是，當生產者向緩沖區(qū)放入8個產品后，wait()方法并沒有使生產者線程們停住，對此表示很疑惑。
*
*/
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
class myProducer implements Runnable
{
private myProAndCon mpc;
myProducer( myProAndCon mpac ){ this.mpc = mpac; }
public void run()
{
try {
while(!Thread.interrupted())
{
//生產者互斥
synchronized (this){
//靜態(tài)計數值達到上限，則wait()阻塞，等待被消費者線程喚醒
while ( mpc.get() >= 8 )
{
System.out.println(mpc.get());
wait();
}
}
Thread.sleep(100);
//未發(fā)生阻塞時，向緩沖區(qū)內放入產品，增加計數值，并喚醒所有阻塞的消費者線程
synchronized ( mpc.c ){
System.out.println("[ P ] The number is " + mpc.inc() );
mpc.c.notifyAll();
}
}
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
class myConsumer implements Runnable
{
private myProAndCon mpc;
myConsumer( myProAndCon mpac ){ this.mpc = mpac; }
public void run()
{
try {
while(!Thread.interrupted())
{
//消費者互斥
synchronized ( this )
{
//當緩沖區(qū)無產品時，消費者線程阻塞，等待被生產者線程喚醒
while ( mpc.get() <= 0 )
wait();
}
Thread.sleep(3000);
//未發(fā)生阻塞時，從緩沖區(qū)取出產品，減少計數值，并喚醒所有阻塞的生產者線程
synchronized (mpc.p){
System.out.println("[ C ] The number is " + mpc.dec() );
mpc.p.notifyAll();
}
}
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
public class myProAndCon {
//public final int S = 8;
//緩沖區(qū)計數器(靜態(tài))以及對其進行的三個synchronized操作
volatile private static int counter = 0;
synchronized static int inc(){ return ++ counter; }
synchronized static int dec(){ return counter -= 2; }
synchronized static int get(){ return counter; }
//構造兩個對象，作為開啟線程的參數
public myConsumer c = new myConsumer(this);
public myProducer p = new myProducer(this);
private ExecutorService exec = Executors.newCachedThreadPool();
public myProAndCon(){
//打開十個生產者線程
for ( int i = 0 ; i < 10 ; i ++ )
exec.execute(p);
//打開五個消費者線程
for ( int i = 0 ; i < 5 ; i ++ )
exec.execute(c);
}
//主函數調用myProAndCon類構造方法，開始執(zhí)行各個線程
public static void main(String[] s)
{
new myProAndCon();
}
}