三種方法實現生產者 消費者模型（Java）

一、wait() / notify()方法

當所有生產者和消費者的目標都達成時，程序結束

class depot 

public
synchronized
void
produce(int val) 
} catch (interruptedexception e) 
}public
synchronized
void
consume(int val) 
} catch (interruptedexception e) 
}public string tostring() 
}// 生產者
class producer 
// 消費產品：新建乙個執行緒向倉庫中生產產品。
public
void
produce(final
int val) 
}.start();
}}// 消費者
class customer 
// 消費產品：新建乙個執行緒從倉庫中消費產品。
public
void
consume(final
int val) 
}.start();
}}

試執行如下：

public

class demo1 
}

thread-0

produce(
60)-
-> left=0,
inc=60,
size=
60thread-4
produce(110)
--> left=70,
inc=40,
size=100
thread-3
consume(150)
<-
-left=50,
dec=100
,size=
0thread-1
produce(120)
--> left=20,
inc=100
,size=100
thread-2
consume(
90)<-
-left=0,
dec=90,
size=
10thread-3
consume(150)
<-
-left=40,
dec=10,
size=
0thread-4
produce(110)
--> left=0,
inc=70,
size=
70thread-3
consume(150)
<-
-left=0,
dec=40,
size=
30thread-1
produce(120)
--> left=0,
inc=20,
size=
50

class depot 

public
void
produce(int val) 
} catch (interruptedexception e) finally 
}public
void
consume(int val) 
} catch (interruptedexception e) finally 
}public string tostring() 
};

class

producer
extends
thread
public
void run()
;for (int i = 0 ; i < 999999999 ; i++ )
catch (exception ex)
system.out.println(getname() + "生產完成：" + bq);}}
}class
consumer
extends
thread
public
void run()
catch (exception ex)
system.out.println(getname() + "消費完成：" + bq);}}
}public
class
blockingqueuetest2
}

生產者消費者模型

1.生產者消費者問題 producer consumer 有限緩衝，多執行緒同步。生產者執行緒和消費者執行緒共享固定大小緩衝區。2.關鍵是保證生產者不會再緩衝區滿時加入資料，消費者不會在緩衝區空時消耗資料。3.解決辦法 讓生產者在緩衝區滿時休眠，等下次消費者消耗緩衝區中的資料的時候，生產者才能被喚醒...

生產者消費者模型

生產者與消費者 3,2,1 三種關係 生產者與消費者 互斥，同步 消費者與消費者 互斥 生產者與生產者 互斥 條件變數 int pthread cond destroy pthread cond t cond int pthread cond init pthread cond t restrict...

生產者消費者模型

當佇列滿時，生產者需要等待佇列有空間才能繼續往裡面放入商品，而在等待的期間內，生產者必須釋放對臨界資源 即佇列 的占用權。因為生產者如果不釋放對臨界資源的占用權，那麼消費者就無法消費佇列中的商品，就不會讓佇列有空間，那麼生產者就會一直無限等待下去。因此，一般情況下，當佇列滿時，會讓生產者交出對臨界資...