1.ReentrantLock實(shí)現(xiàn)

/*** 描述: 一個(gè)初始值為0的變量，兩個(gè)線程對(duì)其交替操作，一個(gè)加一個(gè)減** @author xinjiao.yu@marketin.cn* @create 2020/2/22 11:55* @since 2.16.3*/ class ShareData{private int number = 0;private Lock lock = new ReentrantLock();private Condition condition = lock.newCondition();public void increment() throws Exception{lock.lock();try{// 1判斷while(number != 0){// 等待，不能生產(chǎn)condition.await();}number++;System.out.println(Thread.currentThread().getName()+"\t"+number);// 通知喚醒condition.signalAll();}catch (Exception e){e.printStackTrace();}finally {lock.unlock();}}public void decrement() throws Exception{lock.lock();try{// 1判斷while(number == 0){// 等待，不能生產(chǎn)condition.await();}number--;System.out.println(Thread.currentThread().getName()+"\t"+number);// 通知喚醒condition.signalAll();}catch (Exception e){e.printStackTrace();}finally {lock.unlock();}} } public class ProConsumer_ReentrantLockDemo {public static void main(String[] args) {ShareData shareData = new ShareData();new Thread(()->{for(int i=1;i<=5;i++){try{shareData.increment();}catch (Exception e){e.printStackTrace();}}},"AA").start();new Thread(()->{for(int i=1;i<=5;i++){try{shareData.decrement();}catch (Exception e){e.printStackTrace();}}},"BB").start();} }

2.BlockingQueue實(shí)現(xiàn)

class MyResource{private volatile boolean FLAG = true;private AtomicInteger atomicInteger = new AtomicInteger();private BlockingQueue<String> blockingQueue = null;// 構(gòu)造方法注入public MyResource(BlockingQueue<String> blockingQueue){this.blockingQueue = blockingQueue;System.out.println(blockingQueue.getClass().getName());}public void myProd() throws Exception{String data = null;boolean retValue;while (FLAG){data = atomicInteger.incrementAndGet()+"";retValue = blockingQueue.offer(data,2L, TimeUnit.SECONDS);if(retValue){System.out.println(Thread.currentThread().getName()+"\t 插入隊(duì)列"+data+"成功");}else {System.out.println(Thread.currentThread().getName()+"\t 插入隊(duì)列"+data+"失敗");}TimeUnit.SECONDS.sleep(1);}System.out.println(Thread.currentThread().getName()+"\t 大老板叫停了，表示FLAG=false,生產(chǎn)動(dòng)作結(jié)束");}public void myConsumer() throws Exception{String result = null;while (FLAG){result = blockingQueue.poll(2L,TimeUnit.SECONDS);if(null == result || result.equalsIgnoreCase("")){FLAG = false;System.out.println(Thread.currentThread().getName()+"\t 超過2秒鐘沒有取到蛋糕，消費(fèi)退出");System.out.println();return;}System.out.println(Thread.currentThread().getName()+"\t 消費(fèi)隊(duì)列"+result+"成功");}}public void myStop() throws Exception{this.FLAG=false;} } public class ProConsumer_BlockQueueDemo {public static void main(String[] args) throws Exception{MyResource myResource = new MyResource(new ArrayBlockingQueue<>(3));new Thread(()->{System.out.println(Thread.currentThread().getName()+"\t 生產(chǎn)者線程啟動(dòng)");try {myResource.myProd();} catch (Exception e) {e.printStackTrace();}},"Prod").start();new Thread(()->{System.out.println(Thread.currentThread().getName()+"\t 消費(fèi)者線程啟動(dòng)");try {myResource.myConsumer();} catch (Exception e) {e.printStackTrace();}},"Consumer").start();// 暫停一會(huì)線程TimeUnit.SECONDS.sleep(5);System.out.println();System.out.println();System.out.println("5秒鐘時(shí)間到，大老板main線程叫停，活動(dòng)結(jié)束");myResource.myStop();} }

?

?

總結(jié)

以上是生活随笔為你收集整理的生产者消费者ReentrantLock实现以及BlockingQueue实现的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。