Java多线程与并发库高级应用之阻塞队列BlockingQueue

JDK1.5提供了阻塞队列接口BlockingQueue，它是一个有界阻塞队列。BlockingQueue实现是线程安全的，可以安全地与多个生产者和多个使用者一起使用。

使用时用其实现类
ArrayBlockingQueue，它一个由数组支持的有界阻塞队列。此队列按 FIFO（先进先出）原则对元素进行排序。队列的头部
是在队列中存在时间最长的元素。队列的尾部是在队列中存在时间最短的元素。新元素插入到队列的尾部，队列获取操作则是从队列头部开始获得元素。

这是一个典型的“有界缓存区”，固定大小的数组在其中保持生产者插入的元素和使用者提取的元素。一旦创建了这样的缓存区，就不能再增加其容量。试图向已满队列中放入元素会导致操作受阻塞；试图从空队列中提取元素将导致类似阻塞。

使用构造器ArrayBlockingQueue(int
capacity)可以创建一个带有给定的（固定）容量和默认访问策略的ArrayBlockingQueue。

其put(E
e)方法将指定的元素插入此队列的尾部，如果该队列已满，则等待可用的空间。

take()方法可以获取并移除此队列的头部，在元素变得可用之前一直等待。

见下面程序，程序中两条线程向队列中写入数据，一条线程读取数据。当队列已满时，写入线程阻塞；当队列空时，读取线程阻塞。

[java] view plaincopy

1. public class ArrayBlockingQueueDemo {
2. public static void main(String[] args) {
3. //阻塞队列，队列容量为3


4. final BlockingQueue<Integer> queue = new ArrayBlockingQueue<Integer>(3);
5. //两个线程向队列写入数据


6. for(int i = 0; i < 2; i++){


7. new Thread(){


8. @Override


9. public void run() {


10. while(true){


11. try{


12. Thread.sleep((long)(Math.random()*1000));


13. System.out.println(getName() + "-准备向队列写入数据");


14. queue.put(1);


15. System.out.println(getName() + "-已经向队列写入数据，队列一共有"


16. + queue.size() + "个数据");


17. }catch(InterruptedException e){


18. e.printStackTrace();


19. }


20. }


21. }


22. }.start();


23. }
24. //一个线程读取数据


25. new Thread(){


26. @Override


27. public void run() {


28. while(true){


29. try{


30. Thread.sleep(1000);


31. System.out.println(getName() + "-准备从队列读取数据");


32. queue.take();


33. System.out.println(getName() + "-已经从队列读取数据，队列一共有"


34. + queue.size() + "个数据");


35. }catch(InterruptedException e){


36. e.printStackTrace();


37. }


38. }


39. }


40. }.start();


41. }
42. }

看到当队列已满时，写入线程阻塞知道有一个数据被取出后才能继续写入。

Java多线程与并发库高级应用之阻塞队列BlockingQueue,码迷,mamicode.com