一头扎进多线程-阻塞队列（4）-SynchronousQueue

超、凢脫俗 2022-07-15 05:28 127阅读 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的，所以也可以看到了该队列的转发机制