多线程下的生产者和消费者 - BlockingQueue

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

　　2.BlockingQueue 不接受 null 元素。

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

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

1. import java.util.*; 
2. import java.util.concurrent.*; 
3.  
4. class Producer 
5.     implements Runnable 
6. { 
7.     private BlockingQueue<String> drop; 
8.     List<String> messages = Arrays.asList( 
9.         "Mares eat oats", 
10.         "Does eat oats", 
11.         "Little lambs eat ivy", 
12.         "Wouldn't you eat ivy too?"); 
13.          
14.     public Producer(BlockingQueue<String> d) { this.drop = d; } 
15.      
16.     public void run() 
17.     { 
18.         try 
19.         { 
20.             for (String s : messages) 
21.                 drop.put(s); 
22.             drop.put("DONE"); 
23.         } 
24.         catch (InterruptedException intEx) 
25.         { 
26.             System.out.println("Interrupted! " +  
27.                 "Last one out, turn out the lights!"); 
28.         } 
29.     }     
30. } 
31.  
32. class Consumer 
33.     implements Runnable 
34. { 
35.     private BlockingQueue<String> drop; 
36.     public Consumer(BlockingQueue<String> d) { this.drop = d; } 
37.      
38.     public void run() 
39.     { 
40.         try 
41.         { 
42.             String msg = null; 
43.             while (!((msg = drop.take()).equals("DONE"))) 
44.                 System.out.println(msg); 
45.         } 
46.         catch (InterruptedException intEx) 
47.         { 
48.             System.out.println("Interrupted! " +  
49.                 "Last one out, turn out the lights!"); 
50.         } 
51.     } 
52. } 
53.  
54. public class ABQApp 
55. { 
56.     public static void main(String[] args) 
57.     { 
58.         BlockingQueue<String> drop = new ArrayBlockingQueue(1, true); 
59.         (new Thread(new Producer(drop))).start(); 
60.         (new Thread(new Consumer(drop))).start(); 
61.     } 
62. } 

 本文转自 tianya23 51CTO博客，原文链接：http://blog.51cto.com/tianya23/683090，如需转载请自行联系原作者