SynchronousQueue的简单应用

迈不过友情╰ 2022-08-09 02:09 141阅读 0赞

SynchronousQueue<E>的定义如下

public class SynchronousQueue<E>
    extends AbstractQueue<E>
    implements BlockingQueue<E>, Serializable

从上面可以看出，它实现BlockingQueue<E>，所以是阻塞队列，从名字看，它又是同步的。

它模拟的功能类似于生活中一手交钱一手交货这种情形，像那种货到付款或者先付款后发货模型不适合使用SynchronousQueue。  
首先要知道SynchronousQueue没有容纳元素的能力，即它的isEmpty()方法总是返回true，但是给人的感觉却像是只能容纳一个元素。

另外在创建SynchronousQueue时可以传递一个boolean参数来指定它是否是访问它的线程按遵守FIFO顺序处理，true表示遵守FIFO。

下面使用SynchronousQueue模拟只能生产一个产品的生产者-消费者模型

**\[java\]**  [view plain][] [copy][view plain]

1.  **import** java.util.Random;  
2.  **import** java.util.concurrent.SynchronousQueue;  
3.  **import** java.util.concurrent.TimeUnit;  
4.    
5.  **public** **class** Test19 \{  
6.      **public** **static** **void** main(String\[\] args) \{  
7.          SynchronousQueue<Integer> queue = **new** SynchronousQueue<Integer>();  
8.          **new** Customer(queue).start();  
9.          **new** Product(queue).start();  
10.     \}  
11.     **static** **class** Product **extends** Thread\{  
12.         SynchronousQueue<Integer> queue;  
13.         **public** Product(SynchronousQueue<Integer> queue)\{  
14.             **this**.queue = queue;  
15.         \}  
16.         @Override  
17.         **public** **void** run()\{  
18.             **while**(**true**)\{  
19.                 **int** rand = **new** Random().nextInt(1000);  
20.                 System.out.println("生产了一个产品："\+rand);  
21.                 System.out.println("等待三秒后运送出去...");  
22.                 **try** \{  
23.                     TimeUnit.SECONDS.sleep(3);  
24.                 \} **catch** (InterruptedException e) \{  
25.                     e.printStackTrace();  
26.                 \}  
27.                 queue.offer(rand);  
28.             \}  
29.         \}  
30.     \}  
31.     **static** **class** Customer **extends** Thread\{  
32.         SynchronousQueue<Integer> queue;  
33.         **public** Customer(SynchronousQueue<Integer> queue)\{  
34.             **this**.queue = queue;  
35.         \}  
36.         @Override  
37.         **public** **void** run()\{  
38.             **while**(**true**)\{  
39.                 **try** \{  
40.                     System.out.println("消费了一个产品:"\+queue.take());  
41.                 \} **catch** (InterruptedException e) \{  
42.                     e.printStackTrace();  
43.                 \}  
44.                 System.out.println("------------------------------------------");  
45.             \}  
46.         \}  
47.     \}  
48.     /\*\* 
49.      \* 运行结果： 
50.      \*  生产了一个产品：464 
51.         等待三秒后运送出去... 
52.         消费了一个产品:773 
53.         ------------------------------------------ 
54.         生产了一个产品：547 
55.         等待三秒后运送出去... 
56.         消费了一个产品:464 
57.         ------------------------------------------ 
58.         生产了一个产品：87 
59.         等待三秒后运送出去... 
60.         消费了一个产品:547 
61.         ------------------------------------------ 
62.      \*/  
63. \}  
64.

[view plain]: http://blog.csdn.net/wxwzy738/article/details/8502882#