一头扎进多线程-阻塞队列(4)-SynchronousQueue 男娘i 2022-07-15 05:28 143阅读 0赞 **四.服务员的即时传送-SynchronousQueue** 在现实中我们不仅仅只有自助餐,时候也需要即点即来的一些食品。顾客进入餐厅,点了一个菜,厨师把菜炒好之后拿给服务员,服务员立刻就送到顾客的餐桌上。服务员就是一个厨师与顾客之间的传递者,服务员不是选菜区,不能把做好的菜让服务员端着等待顾客拿,只能是顾客要,就立刻把菜传递过去。这样的作用机制就好像SynchronousQueue一样,该阻塞队列不缓存任何资源,当生产者把资源往该队列里面放的时候,生产者就会被阻塞,一直等到有消费者求资源的时候立刻把资源转接到消费者的手里。同个道理,当消耗者进行请求的时候,就会被阻塞,一直等到有生产者把资源往队列里面放的时候,就立刻转接资源。下面我们通过代码理解一下该队列的作用。 public class SynChronizedQueueTest { public static void main(String[] args){ SynchronousQueue<String> waiter = new SynchronousQueue<String>();//服务员 Thread fenOffer = new Thread(new Runnable() { @Override public void run() { while(true){ String fen = "肠粉"; System.out.println("生产了一盘肠粉"); try { waiter.put(fen);//这里将会阻塞 } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("传递给了服务员"); try { Thread.sleep(3000); } catch (InterruptedException e) { e.printStackTrace(); } } } }); Thread fenConsumer = new Thread(new Runnable(){ @Override public void run() { while(true){ String fen =null; try { fen = waiter.take(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("顾客吃了一盘"+fen); try { Thread.sleep(6000); } catch (InterruptedException e) { e.printStackTrace(); } } } }); fenConsumer.start(); fenOffer.start(); while(true){ //主线程监听队列内部状态 String fen = waiter.peek(); System.out.println("waiter peek : "+fen); System.out.println("waiter size:"+waiter.size()); try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } } } } 结果: waiter peek : null waiter size:0 生产了一盘肠粉 顾客吃了一盘肠粉 传递给了服务员 waiter peek : null waiter size:0 生产了一盘肠粉 waiter peek : null waiter size:0 waiter peek : null waiter size:0 顾客吃了一盘肠粉 传递给了服务员 waiter peek : null waiter size:0 生产了一盘肠粉 waiter peek : null waiter size:0 waiter peek : null waiter size:0 传递给了服务员 顾客吃了一盘肠粉 waiter peek : null waiter size:0 生产了一盘肠粉 waiter peek : null waiter size:0 waiter peek : null waiter size:0 传递给了服务员 顾客吃了一盘肠粉 waiter peek : null waiter size:0 生产了一盘肠粉 waiter peek : null waiter size:0 waiter peek : null waiter size:0 传递给了服务员 顾客吃了一盘肠粉 waiter peek : null waiter size:0 生产了一盘肠粉 waiter peek : null waiter size:0 waiter peek : null waiter size:0 传递给了服务员 顾客吃了一盘肠粉 从上面结果可以看到”传递给了服务员”,”顾客吃了一盘肠粉”,这两者总是几乎同时输出的,证明该队列只是扮演着传递资源的作用,而且是很快的传递资源。且通过peek,size可以看到该队列内部状态都是为null的,所以也可以看到了该队列的转发机制
还没有评论,来说两句吧...