生产者/消费者模式实现

　　生产者-消费者也有多种实现方式。

　　　　(1)常见的就是synchronized结合wait+notify实现

　　　　(2)用Lock类实现

　　　　(3)使用BlockingQueue阻塞队列实现

　　一个线程向集合中添加元素，两个线程从集合中删除元素，与之前等待/通知博客的最后一个案例类似。

结果:

18:16:23 [cn.qlq.thread.seven.Demo1]-[INFO] 添加元素->0,threadName->B

18:16:23 [cn.qlq.thread.seven.Demo1]-[INFO] list.remove ->0, threadName->sub2

18:16:23 [cn.qlq.thread.seven.Demo1]-[INFO] 添加元素->1,threadName->B

18:16:23 [cn.qlq.thread.seven.Demo1]-[INFO] list.remove ->1, threadName->sub1

18:16:23 [cn.qlq.thread.seven.Demo1]-[INFO] 添加元素->2,threadName->B

18:16:23 [cn.qlq.thread.seven.Demo1]-[INFO] list.remove ->2, threadName->sub2

18:16:23 [cn.qlq.thread.seven.Demo1]-[INFO] 添加元素->3,threadName->B

18:16:23 [cn.qlq.thread.seven.Demo1]-[INFO] list.remove ->3, threadName->sub1

18:16:23 [cn.qlq.thread.seven.Demo1]-[INFO] 添加元素->4,threadName->B

18:16:23 [cn.qlq.thread.seven.Demo1]-[INFO] list.remove ->4, threadName->sub2

　　假死的现象其实就是进入waiting状态。如果全部线程都进入waiting状态，则程序就不再执行任何业务功能了，整个项目呈停止状态。

　　例如两个生产者两个消费者最后处于假死状态的例子:

18:49:23 [cn.qlq.thread.seven.Demo2]-[INFO] 进入等待***,threadName->sub1

18:49:23 [cn.qlq.thread.seven.Demo2]-[INFO] 进入等待***,threadName->sub2

18:49:24 [cn.qlq.thread.seven.Demo2]-[INFO] 添加元素->0,threadName->add1

18:49:24 [cn.qlq.thread.seven.Demo2]-[INFO] 进入等待***,threadName->add1

18:49:24 [cn.qlq.thread.seven.Demo2]-[INFO] 退出等待***,threadName->sub1

18:49:24 [cn.qlq.thread.seven.Demo2]-[INFO] list.remove ->0, threadName->sub1

18:49:24 [cn.qlq.thread.seven.Demo2]-[INFO] 进入等待***,threadName->sub1

18:49:24 [cn.qlq.thread.seven.Demo2]-[INFO] 退出等待***,threadName->sub2

18:49:24 [cn.qlq.thread.seven.Demo2]-[INFO] 进入等待***,threadName->sub2

18:49:25 [cn.qlq.thread.seven.Demo2]-[INFO] 添加元素->add2,threadName->{}

18:49:25 [cn.qlq.thread.seven.Demo2]-[INFO] 退出等待***,threadName->add1

18:49:25 [cn.qlq.thread.seven.Demo2]-[INFO] 进入等待***,threadName->add1

18:49:25 [cn.qlq.thread.seven.Demo2]-[INFO] 进入等待***,threadName->add2

18:49:35 [cn.qlq.thread.seven.Demo2]-[INFO] sub1 state->WAITING

18:49:35 [cn.qlq.thread.seven.Demo2]-[INFO] sub2 state->WAITING

18:49:35 [cn.qlq.thread.seven.Demo2]-[INFO] add1 state->WAITING

18:49:35 [cn.qlq.thread.seven.Demo2]-[INFO] add2 state->WAITING

　　

解释一下上面的线程假死的原因:

　　由于唤醒线程调用的是notify()唤醒单个线程，所以有可能唤醒的是同类的线程，也就是生产者唤醒的是生产者，消费者唤醒的是消费者。导致最后四个线程都处于waiting状态。

解决办法:

　　唤醒的时候采用notifyAll()唤醒所有的线程唤醒所有的线程，避免只唤醒同类线程。

　　为了避免上面的假死线下,唤醒的时候采用notifyAll()唤醒所有的线程唤醒所有的线程，避免只唤醒同类线程。

　　唤醒的时候也唤醒异类，这样就不会出现假死的状态了，程序会一直运行下去。

　　附上一个多生产与一个消费者的例子。大体的思路是对资源加锁，在线程中通过while(true)不停的调用资源的add()方法和remove()方法，两个方法都是同步方法，需要同步是对当前对象加锁。每个对象都有一个阻塞队列，一个就绪队列。

　　在学习完wait/notify之后再次重写下面代码就清晰多了。

 　

　　生产者和消费者分别阻塞在两个条件下面的例子

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > pro1 生产元素 0

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > pro1 生产元素 1

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > pro1 生产元素 2

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > con1 消费元素 0

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > con1 消费元素 1

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > con1 消费元素 2

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > pro1 生产元素 3

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > pro1 生产元素 4

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > pro1 生产元素 5

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > con1 消费元素 3

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > con1 消费元素 4

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > con2 消费元素 5

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > pro1 生产元素 6

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > pro1 生产元素 7

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > pro1 生产元素 8

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > con2 消费元素 6

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > con2 消费元素 7

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > con2 消费元素 8

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > pro1 生产元素 9

13:31:28 [cn.qlq.thread.eleven.Demo4]-[INFO] threadName - > con2 消费元素 9

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > pro1 生产元素 0

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > pro1 生产元素 1

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > pro1 生产元素 2

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > con1 消费元素 0

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > con1 消费元素 1

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > con1 消费元素 2

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > pro1 生产元素 3

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > pro1 生产元素 4

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > pro2 生产元素 0

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > con1 消费元素 3

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > con1 消费元素 4

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > con2 消费元素 0

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > pro2 生产元素 1

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > pro2 生产元素 2

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > pro2 生产元素 3

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > con2 消费元素 1

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > con2 消费元素 2

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > con2 消费元素 3

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > pro2 生产元素 4

13:36:49 [cn.qlq.thread.eleven.Demo5]-[INFO] threadName - > con2 消费元素 4

　　参考我的另一篇博客:https://www.cnblogs.com/qlqwjy/p/10175201.html 

【当你用心写完每一篇博客之后,你会发现它比你用代码实现功能更有成就感!】