線程通信之生產(chǎn)者消費者阻塞隊列版

ProdConsumer_BlockQueueDemo.java

import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger;class MyResource{private volatile boolean FLAG = true;//默認開啟，進行生產(chǎn)+消費private AtomicInteger atomicInteger = new AtomicInteger();BlockingQueue<String> blockingQueue = null;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插入隊列"+data+"成功");}else{System.out.println(Thread.currentThread().getName()+"\t插入隊列"+data+"失敗");}TimeUnit.SECONDS.sleep(1);}System.out.println(Thread.currentThread().getName()+"\t生產(chǎn)停止");}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秒，消費退出");System.out.println();System.out.println();return;}System.out.println(Thread.currentThread().getName()+"\t消費隊列"+result+"成功");}}public void stop() throws Exception{this.FLAG = false;} }/* * volatile/CAS/atomicInteger/BlockQueue/線程交互/原子引用 * */public class ProdConsumer_BlockQueueDemo {public static void main(String[] args) throws Exception{MyResource myResource = new MyResource(new ArrayBlockingQueue<>(10));new Thread(()->{System.out.println(Thread.currentThread().getName()+"\t 生產(chǎn)線程啟動");System.out.println();System.out.println();try{myResource.myProd();}catch (Exception e){e.printStackTrace();}},"Prod").start();new Thread(()->{System.out.println(Thread.currentThread().getName()+"\t 消費線程啟動");try{myResource.myConsumer();}catch (Exception e){e.printStackTrace();}},"Consumer").start();try{TimeUnit.SECONDS.sleep(5);}catch (InterruptedException e){e.printStackTrace();}System.out.println();System.out.println();System.out.println();System.out.println("5秒鐘到，main停止");myResource.stop();} }

總結(jié)

以上是生活随笔為你收集整理的线程通信之生产者消费者阻塞队列版的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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