参考：http://www.ibm.com/developerworks/cn/java/j-5things4.html
【关于 java.util.concurrent 您不知道的 5 件事，第 1 部分】
1，BlockingQueue
public class ABQApp {
public static void main(String[] args) {
BlockingQueue<String> drop = new ArrayBlockingQueue<String>(1, true);
new Thread(new Producer(drop)).start();
new Thread(new Consumer(drop)).start();
}
}
class Producer implements Runnable {
private BlockingQueue<String> drop;
List<String> messages = Arrays.asList(
"Mares eat oats",
"Does eat oats",
"Little lambs eat ivy",
"Wouldn't you eat ivy too?");
public Producer(BlockingQueue<String> d) { this.drop = d; }
public void run() {
try {
for (String s : messages)
drop.put(s);
drop.put("DONE");
} catch (InterruptedException intEx) {
System.out.println("Interrupted! " +
"Last one out, turn out the lights!");
}
}
}
class Consumer implements Runnable {
private BlockingQueue<String> drop;
public Consumer(BlockingQueue<String> d) { this.drop = d; }
public void run() {
try {
String msg = null;
while (!((msg = drop.take()).equals("DONE")))
System.out.println(msg);
} catch (InterruptedException intEx) {
System.out.println("Interrupted! " +
"Last one out, turn out the lights!");
}
}
}
2，SynchronousQueues
public class SynQApp {
public static void main(String[] args) {
BlockingQueue<String> drop = new SynchronousQueue<String>();
(new Thread(new Producer(drop))).start();
(new Thread(new Consumer(drop))).start();
}
}
class Producer implements Runnable {
private BlockingQueue<String> drop;
List<String> messages = Arrays.asList(
"Mares eat oats",
"Does eat oats",
"Little lambs eat ivy",
"Wouldn't you eat ivy too?");
public Producer(BlockingQueue<String> d) { this.drop = d; }
public void run() {
try {
for (String s : messages)
drop.put(s);
drop.put("DONE");
} catch (InterruptedException intEx) {
System.out.println("Interrupted! " +
"Last one out, turn out the lights!");
}
}
}
class Consumer implements Runnable {
private BlockingQueue<String> drop;
public Consumer(BlockingQueue<String> d) { this.drop = d; }
public void run() {
try {
String msg = null;
while (!((msg = drop.take()).equals("DONE")))
System.out.println(msg);
} catch (InterruptedException intEx) {
System.out.println("Interrupted! " +
"Last one out, turn out the lights!");
}
}
}
总的来说SynchronousQueue，就保证了放一个读一个，线程同步了，然后ArrayBlockingQueue<String>(1, true);就和SynchronousQueue一样了。