使用SynchronousQueue

最近需要实现这样一个接口：
每次调用接口，触发一个线程生产一个对象，然后当前线程消费这个对象返回。

可以使用AtomicReference和CountDownLatch实现

public class Main {
    public static void main(String[] args) throws InterruptedException {
        AtomicReference<String> msg = new AtomicReference<>();
        CountDownLatch countDownLatch = new CountDownLatch(1);
        new Thread(() -> {
            try {
                // 模拟耗时操作
                TimeUnit.SECONDS.sleep(5);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            msg.set("abc");
            countDownLatch.countDown();
        }).start();
        countDownLatch.await(10, TimeUnit.SECONDS);
        System.out.println(msg.get());
    }
}

使用SynchronousQueue

public class Main {
    public static void main(String[] args) throws InterruptedException {
        SynchronousQueue<String> queue = new SynchronousQueue<>();
        new Thread(() -> {
            try {
                // 模拟耗时操作
                TimeUnit.SECONDS.sleep(5);
                queue.offer("abc", 10, TimeUnit.SECONDS);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();
        System.out.println(queue.poll(10, TimeUnit.SECONDS));
    }
}

SynchronousQueue是一种容量为0的阻塞队列，其size方法固定返回0。

    public int size() {
        return 0;
    }

虽然内部没有暂存生产者生产的对象的容器，但却有线程的容器。所以依然允许多个线程同时put和take。

提供了6个存取方法，它们的区别如下表所示：