SynchronousQueue的简单应用2

Love The Way You Lie 2022-04-04 08:54 229阅读 0赞

转：[http://blog.csdn.net/orgcheng/article/details/7985503][http_blog.csdn.net_orgcheng_article_details_7985503]

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模拟只能生产一个产品的生产者-消费者模型

import java.util.Random;
    import java.util.concurrent.SynchronousQueue;
    import java.util.concurrent.TimeUnit;
    
    public class Test19 {
    	public static void main(String[] args) {
    		SynchronousQueue<Integer> queue = new SynchronousQueue<Integer>();
    		new Customer(queue).start();
    		new Product(queue).start();
    	}
    	static class Product extends Thread{
    		SynchronousQueue<Integer> queue;
    		public Product(SynchronousQueue<Integer> queue){
    			this.queue = queue;
    		}
    		@Override
    		public void run(){
    			while(true){
    				int rand = new Random().nextInt(1000);
    				System.out.println("生产了一个产品："+rand);
    				System.out.println("等待三秒后运送出去...");
    				try {
    					TimeUnit.SECONDS.sleep(3);
    				} catch (InterruptedException e) {
    					e.printStackTrace();
    				}
    				queue.offer(rand);
    			}
    		}
    	}
    	static class Customer extends Thread{
    		SynchronousQueue<Integer> queue;
    		public Customer(SynchronousQueue<Integer> queue){
    			this.queue = queue;
    		}
    		@Override
    		public void run(){
    			while(true){
    				try {
    					System.out.println("消费了一个产品:"+queue.take());
    				} catch (InterruptedException e) {
    					e.printStackTrace();
    				}
    				System.out.println("------------------------------------------");
    			}
    		}
    	}
    	/**
    	 * 运行结果：
    	 *  生产了一个产品：464
    		等待三秒后运送出去...
    		消费了一个产品:773
    		------------------------------------------
    		生产了一个产品：547
    		等待三秒后运送出去...
    		消费了一个产品:464
    		------------------------------------------
    		生产了一个产品：87
    		等待三秒后运送出去...
    		消费了一个产品:547
    		------------------------------------------
    	 */
    }

[http_blog.csdn.net_orgcheng_article_details_7985503]: http://blog.csdn.net/orgcheng/article/details/7985503