JUC - SynchronousQueue

SynchronousQueue是一种阻塞队列，其中每个插入操作必须等待另一个线程的对应移除操作 ，反之亦然。同步队列没有任何内部容量，甚至连一个队列的容量都没有。不能在同步队列上进行 peek，因为仅在试图要移除元素时，该元素才存在；除非另一个线程试图移除某个元素，否则也不能（使用任何方法）插入元素；也不能迭代队列，因为其中没有元素可用于迭代。

队列的头 是尝试添加到队列中的首个已排队插入线程的元素；如果没有这样的已排队线程，则没有可用于移除的元素并且 poll() 将会返回 null。对于其他 Collection 方法（例如 contains），SynchronousQueue 作为一个空 collection。此队列不允许 null 元素。

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

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

例子：

public static void main(String[] args) {

SynchronousQueue q = new SynchronousQueue();

Thread p = new Thread(new Producer(q, 10), "producer");

Thread c1 = new Thread(new Consumer(q), "consumer1");

Thread c2 = new Thread(new Consumer(q), "consumer2");

c1.setDaemon(true);

c2.setDaemon(true);

p.start();

try {

Thread.sleep(3000);

} catch (InterruptedException e) {

e.printStackTrace();

}

c1.start();

c2.start();

}

static class Producer implements Runnable{

private SynchronousQueue q;

private int count;

private SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss");

public Producer(SynchronousQueue q, int count) {

this.q = q;

this.count = count;

}

public void run() {

String tname = Thread.currentThread().getName();

for(int i=0; i

try {

System.out.println(tname + " " + sdf.format(new Date()) + " begin to put - " + i);

q.put("item"+i);

System.out.println(tname + " " + sdf.format(new Date()) + " put finish - " + i);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

}

static class Consumer implements Runnable{

private SynchronousQueue q;

private SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss");

public Consumer(SynchronousQueue q) {

this.q = q;

}

@Override

public void run() {

String tname = Thread.currentThread().getName();

for(;;){

try {

System.out.println(tname + " " + sdf.format(new Date()) + " begin to take");

String s = q.take();

System.out.println(tname + " " + sdf.format(new Date()) + " take - " + s);

Thread.sleep(2000);

} catch (Exception e) {

e.printStackTrace();

}

}

}

}