线程通信
应用场景:生产者和消费者问题
这是一个线程同步问题,生产者和消费者共享同一个资源,并且生产者和消费者之间相互依赖,互为条件。
Java中提供了几个方法解决线程之间的通信问题:
①wait() 表示线程会一直等待,直到其他线程通知,与sleep不同,会释放锁
②wait(long timeout) 指定等待的毫秒数
③notify() 唤醒一个处于等待状态的线程
④notifyAll() 唤醒同一个对象上所有调用wait方法的线程,优先级别高的线程优先调度
均是Object类的方法,都只能在同步方法或者同步代码块中使用,否则会抛出异常IIIegalMonitorStateException
问题解决方式1
并发协作模型“生产者/消费者问题”---管程法
· 生产者:负责生产数据的模块(可能是方法、对象、线程、进程);
· 消费者:负责处理数据的模块(可能是方法、对象、线程、进程);
· 缓冲区:消费者不能直接使用生产者的数据,他们之间有个“缓冲区”。
生产者将生产好的数据放入缓冲区,消费者从缓冲区中拿出数据
package com.wang.ssynchronized;
//测试生产者/消费者问题---利用缓冲区解决(管程法)
//需要有生产者、消费者、产品、缓冲区
public class TestProCus {
public static void main(String[] args) {
SynContainer container=new SynContainer();
new Productor(container).start();
new Consumer(container).start();
}
}
//生产者
class Productor extends Thread{
SynContainer container;
public Productor(SynContainer container){
this.container=container;
}
//需要生产方法