消费者和生产者模式

用继承Thread方式，用wait和notifyAll方法实现。

消费者和生产者模式的特点

1. 什么时候生产：仓库没有满的时候，生产者这可以生产，消费者也可以消费，仓库满的时候停止生产
2. 什么时候消费: 仓库有货的时候消费，没有货不能消费
3. 通知生产：消费者发现没有货，消费者通知生产者生产
4. 通知消费：生产者生产出产品后，通知消费者消费

代码实现

package com.java.javabase.thread.base;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;/*1. 什么时候生产：仓库没有满的时候，生产者这可以生产，消费者也可以消费，仓库满的时候停止生产2. 什么时候消费: 仓库有货的时候消费，没有货不能消费3. 通知生产：消费者发现没有货，消费者通知生产者生产4. 通知消费：生产者生产出产品后，通知消费者消费*/
@Data
@Slf4j
@AllArgsConstructor
@RequiredArgsConstructor
class Dept {private int capacity;private int size;/*@param val 是生产的产品数量*/public synchronized void produce(int val) {//int remainder = val;while (remainder > 0) {if (size >= capacity) {try {//仓库满了，等待不在执行生产wait();} catch (InterruptedException e) {e.printStackTrace();}}int incre = (size + remainder) > capacity ? capacity - size : remainder;size += incre;remainder -= incre;log.info("produce {} .depet increment {}, remainder {} ,current size is {}",val,incre, remainder, size);//结束生产，通知消费或者生产notifyAll();}}public synchronized void custom(int val) {int remainder = val;while(remainder>0){if(size<=0){try {//仓库无货，等待不在消费wait();} catch (InterruptedException e) {e.printStackTrace();}}int descre =(size<remainder)?size:remainder;size -=descre;remainder -=descre;log.info("custom {}. depet descrement {}, remainder {} ,current size is {}",val,descre, remainder, size);//结束消费，通知消费或者生产notifyAll();}}
}@AllArgsConstructor
class Producer {private Dept dept;public void produce(final int val) {new Thread() {@Overridepublic void run() {dept.produce(val);}}.start();}}@AllArgsConstructor
class Custom {private Dept dept;public void custom(final int val) {new Thread() {@Overridepublic void run() {dept.custom(val);}}.start();}}public class DemoProCustomTest {public static void main(String[] args) {Dept dept =new Dept(100,0);Producer producer =new Producer(dept);Custom custom =new Custom(dept);producer.produce(100);producer.produce(190);custom.custom(150);custom.custom(80);}
}

日志结果输出

因为多线程，所以下面的结果只是其中之一的可能性

2019-07-31 19:10:13,297   [Thread-0] INFO  Dept  - produce 100 .depet increment 100, remainder 0 ,current size is 100
2019-07-31 19:10:13,299   [Thread-3] INFO  Dept  - custom 80. depet descrement 80, remainder 0 ,current size is 20
2019-07-31 19:10:13,299   [Thread-2] INFO  Dept  - custom 150. depet descrement 20, remainder 130 ,current size is 0
2019-07-31 19:10:13,300   [Thread-1] INFO  Dept  - produce 190 .depet increment 100, remainder 90 ,current size is 100
2019-07-31 19:10:13,300   [Thread-2] INFO  Dept  - custom 150. depet descrement 100, remainder 30 ,current size is 0
2019-07-31 19:10:13,300   [Thread-1] INFO  Dept  - produce 190 .depet increment 90, remainder 0 ,current size is 90
2019-07-31 19:10:13,300   [Thread-2] INFO  Dept  - custom 150. depet descrement 30, remainder 0 ,current size is 60