一种阻塞队列，其中每个插入操作必须等待另一个线程的对应移除操作 ，反之亦然。同步队列没有任何内部容量，甚至连一个队列的容量都没有。不能在同步队列上进行peek，因为仅在试图要移除元素时，该元素才存在；除非另一个线程试图移除某个元素，否则也不能（使用任何方法）插入元素；也不能迭代队列，因为其中没有元素可用于迭代。队列的头 是尝试添加到队列中的首个已排队插入线程的元素；如果没有这样的已排队线程，则没有可用于移除的元素并且poll()将会返回null。对于其他Collection方法（例如contains），SynchronousQueue作为一个空 collection。此队列不允许null元素。

同步队列类似于 CSP 和 Ada 中使用的 rendezvous 信道。它非常适合于传递性设计，在这种设计中，在一个线程中运行的对象要将某些信息、事件或任务传递给在另一个线程中运行的对象，它就必须与该对象同步。

对于正在等待的生产者和使用者线程而言，此类支持可选的公平排序策略。默认情况下不保证这种排序。但是，使用公平设置为true所构造的队列可保证线程以 FIFO 的顺序进行访问。

ExecutorService pool = Executors.newCachedThreadPool(); 就是用的SynchronousQueue队列。

package com.lucky.concurrent.queue;import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.SynchronousQueue;public class SynchronousQueueTest {private SynchronousQueue<String> queue = new SynchronousQueue<String>();private static class SynchronousQueueWrite implements Runnable {private SynchronousQueue<String> queue;private int i ;SynchronousQueueWrite(SynchronousQueue<String> queue,int i) {this.queue = queue;this.i = i ;}@Overridepublic void run() {try {queue.put(i+"");} catch (InterruptedException e) {e.printStackTrace();}}}private static class SynchronousQueueRead implements Runnable {private SynchronousQueue<String> queue;SynchronousQueueRead(SynchronousQueue<String> queue) {this.queue = queue;}@Overridepublic void run() {try {System.out.println("take: "+queue.take());} catch (InterruptedException e) {e.printStackTrace();}}}public static void main(String[] args) {new SynchronousQueueTest().run();}public void run() {ExecutorService pool = Executors.newCachedThreadPool();for (int i = 0; i < 10; i++) {pool.execute(new SynchronousQueueWrite(queue,i));pool.execute(new SynchronousQueueRead(queue));System.out.println("queue size: "+queue.size());}pool.shutdown();}
}

运行结果：

查看运行结果：queue大小一直是0。
注意事项：
 注意1：它一种阻塞队列，其中每个 put 必须等待一个 take，反之亦然。 同步队列没有任何内部容量，甚至连一个队列的容量都没有。
 注意2：它是线程安全的，是阻塞的。
 注意3:不允许使用 null 元素。
 注意4：公平排序策略是指调用put的线程之间，或take的线程之间。
 公平排序策略可以查考ArrayBlockingQueue中的公平策略。
 注意5:SynchronousQueue的以下方法很有趣：
    * iterator() 永远返回空，因为里面没东西。
    * peek() 永远返回null。
    * put() 往queue放进去一个element以后就一直wait直到有其他thread进来把这个element取走。
    * offer() 往queue里放一个element后立即返回，如果碰巧这个element被另一个thread取走了，offer方法返回true，认为offer成功；否则返回false。
    * offer(2000, TimeUnit.SECONDS) 往queue里放一个element但是等待指定的时间后才返回，返回的逻辑和offer()方法一样。
    * take() 取出并且remove掉queue里的element（认为是在queue里的。。。），取不到东西他会一直等。
    * poll() 取出并且remove掉queue里的element（认为是在queue里的。。。），只有到碰巧另外一个线程正在往queue里offer数据或者put数据的时候，该方法才会取到东西。否则立即返回null。
    * poll(2000, TimeUnit.SECONDS) 等待指定的时间然后取出并且remove掉queue里的element,其实就是再等其他的thread来往里塞。
    * isEmpty()永远是true。
    * remainingCapacity() 永远是0。
    * remove()和removeAll() 永远是false。