生产者-消费者 

  生产者消费者模式是一个非常经典的多线程模式，比如我们用到的Mq就是其中一种具体实现

  在该模式中 通常会有2类线程，消费者线程和生产者线程

 生产者提交用户请求 消费者负责处理生产者提交的任务，在消费者和生产者之间共享内存缓存区进行通信

  常见的实现 可以 通过 wait/notifyAll来  或者 阻塞队列来实现 下面我来演示下通过 wait/notifyAll 来实现。。。

下面是代码演示

public class Storage
      
        {	LinkedList
       
         list = new LinkedList<>();	private Integer maxSize;	public Integer getMaxSize() {		return maxSize;	}	public void setMaxSize(Integer maxSize) {		this.maxSize = maxSize;	}	public T consumer() {		synchronized (list) {			if (list == null || list.size() == 0) {				try {					System.out.println(Thread.currentThread().getName() + " 等待  ");					list.wait();				} catch (InterruptedException e) {					e.printStackTrace();				}			} else {				T t = list.remove();				try {					Thread.sleep(200);				} catch (InterruptedException e) {					e.printStackTrace();				}				System.out.println(Thread.currentThread().getName() + " 消费  " + t);				if (list.size() == 0) { // 消费完了 通知生产者 继续生产					list.notifyAll();				}				return t;			}		}		return null;	}	public void producer(T t) {		synchronized (list) {			if (list.size() == maxSize.intValue()) {				System.out.println(Thread.currentThread().getName() + " 仓库已满 暂停生产  ");				try {					list.wait();				} catch (InterruptedException e) {					e.printStackTrace();				}			} else {				list.add(t);				System.out.println(Thread.currentThread().getName() + " 生产  " + t);				list.notifyAll();			}		}	}	public static void main(String[] args) {		Storage
        
          storage = new Storage<>();		storage.setMaxSize(5);		AtomicInteger numberGenarnate = new AtomicInteger(0);		ExecutorService consumerService = Executors.newCachedThreadPool();		for (int i = 0; i < 3; i++) {			Runnable run = new Runnable() {				@Override				public void run() {					while (true) {						storage.consumer();					}				}			};			consumerService.submit(run);		}		for (int i = 0; i < 1; i++) {			Runnable run = new Runnable() {				@Override				public void run() {					while (true) {						storage.producer(numberGenarnate.incrementAndGet());					}				}			};			consumerService.submit(run);		}		consumerService.shutdown();	}}
        
       
      

运行结果如下

 

 　总结：对于消费者生产者模式 要理解其思想。实际开发中。mq（消息队列）就是典型的应用。

       对于mq这里多说几句，关于技术选型：：：

       Mq适用于生产者生产很多   消费者处理不过来的情况 。如果消费者处理能力很强，就不要用mq了，直接使用nio框架（mina   or  netty）