1.应用场景:
假设仓库中只能放一件产品,生产者将生产出来的产品放入仓库,消费者将仓库中的产品取走。
如果仓库中没有产品,则生产者将产品放入仓库,否则停止生产并等待,知道仓库中的产品被消费者取走为止。
如果仓库中放有产品,则消费者将产品取走消费,否则停止消费并等待,知道仓库中再次放入产品为止。
2.问题分析:
这是一个线程同步问题,生产者和消费者共享同一个资源,并且生产者和消费者之间相互依赖,互为条件。
对于生产者,没有生产产品之前,要通知消费者等待,而生产了产品之后,又需要通知消费者消费。
对于消费者,在消费之后,要通知生产者已经结束消费,需要生产新的产品以供消费。
在这个问题中,仅有synchronized是不够的,因为synchronized可以实现同步,但是实现不了不同线程之间的通信。
这就需要用到上述的几个方法。他们都是Object类的方法,都只能在同步方法或者同步代码块中使用。
3.解决方式:
(1)并发协作模型:管程法
(2)信号灯法
4.具体实现:
(1)管程法:
生产者将生产好的数据放入缓冲区,消费者从缓冲区拿走数据。
生产者:负责生产数据的模块(可能是方法、对象、线程、进程);
消费者:负责处理数据的模块(可能是方法、对象、线程、进程);
缓冲区:消费者不能直接使用生产者的数据,他们之间有个“缓冲区”;
(2)信号灯法
通过一个标志位来实现