1、BlockingQueue：支持两个附加操作的 Queue，这两个操作是：检索元素时等待队列变为非空，以及存储元素时等待空间变得可用。

2、BlockingQueue 不接受 null 元素。

3、BlockingQueue 可以是限定容量的。

4、BlockingQueue 实现是线程安全的。Queue不是线程安全的。因此可以将Blockingqueue用于用于生产者-使用者队列。

根据Api修改的一个例子，大家可以修改自己体验BlockingQueue的使用

package test;

import java.util.concurrent.ArrayBlockingQueue;

import java.util.concurrent.BlockingQueue;

/**

* 生产者

*/

class Producer implements Runnable {

private final BlockingQueue queue;

Producer（BlockingQueue q） {

queue = q;

}

pubpc void run（） {

try {

for （int i = 0; i 《 3; i++） {

queue.put（produce（））;

System.out.println（“生产后：”+queue.peek（））;

}

} catch （InterruptedException ex） {

ex.printStackTrace（）;

}

}

Character produce（） {

char c = （char） （Math.random（） * 26 + ‘A’）;

System.out.println（“生产前：” + c）;

return c;

}

}

/**

* 消费者

*/

class Consumer implements Runnable {

private final BlockingQueue queue;

Consumer（BlockingQueue q） {

queue = q;

}

pubpc void run（） {

try {

while （true） {

consume（queue.take（））;

//Thread.sleep（100）;

}

} catch （InterruptedException ex） {

ex.printStackTrace（）;

}

}

void consume（Character c） {

System.out.println（“消费：” + c）;

}

}

/**

* 一个生产者、两个消费者

*

*/

class Setup {

pubpc static void main（String［］ args） {

BlockingQueue q = new ArrayBlockingQueue（1）;

Producer p = new Producer（q）;

Consumer c1 = new Consumer（q）;

Consumer c2 = new Consumer（q）;

new Thread（p）.start（）;

new Thread（c1）.start（）;

new Thread（c2）.start（）;

}

}

–EOF–

评分：0