import java.util.concurrent.locks.*;public class Test23 {public static void main(String[] args) {Resource r = new Resource();String x = "黃燜雞";PutX px = new PutX(r, x);TakeX tx = new TakeX(r, x);Thread t0 = new Thread(px);Thread t1 = new Thread(px);Thread t2 = new Thread(tx);Thread t3 = new Thread(tx);t0.start();t1.start();t2.start();t3.start();} }class Resource {Lock lock = new ReentrantLock();Condition full = lock.newCondition();Condition empty = lock.newCondition();private String[] item = new String[400];private int taker = 0;private int puter = 0;private int count = 0;public void put(String x) {while (true) {lock.lock();//用while不用if是由于當多個線程在這里等待后，被喚醒，須要又一次推斷這個條件while (count == item.length) {try {full.await();} catch (InterruptedException e) {}}item[puter] = x;System.out.println(Thread.currentThread().getName() + "..." + count+ "...put.." + x);if (puter == item.length - 1) {puter = -1;empty.signalAll();}++count;++puter;lock.unlock();}}public void take(String x) {while (true) {lock.lock();while (count == 0) {try {empty.await();} catch (InterruptedException e) {}}x = item[taker];System.out.println(Thread.currentThread().getName() + "..."+ (count - 1) + "..take......" + x);if (taker == item.length - 1) {taker = -1;full.signalAll();}--count;++taker;lock.unlock();}} }class PutX implements Runnable {Resource r;String x;PutX(Resource r, String x) {this.r = r;this.x = x;}public void run() {r.put(x);} }class TakeX implements Runnable {Resource r;String x;TakeX(Resource r, String x) {this.r = r;this.x = x;}public void run() {r.take(x);} }

轉載于:https://www.cnblogs.com/zfyouxi/p/5094323.html

總結

以上是生活随笔為你收集整理的多线程之多生产多消费者的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。