线程间通信-消费者生产者模式
同步锁池:同步锁必须选择多个线程共同的资源对象. 当前生产者在生产数据的时候(先拥有同步锁),其他线程就在锁池中等待获取锁.当线程执行完同步代码块的时候,就会释放同步锁,其他线程开始抢锁的使用权
注意:多个线程只有使用相同的一个对象的时候,多线程之间才有互斥效果.我们把这个用来做互斥的对象称之为,同步监听对象/同步锁.同步锁对象可以选择任意类型的对象即可,只需要保证多个线程使用的是相同锁对象即可.因为,只有同步监听锁对象才能调用wait和notify方法,所以,wait和notify方法应该存在于Object类中,而不是Thread类中.
线程通信-wait和notify方法介绍:java.lang.Object类提供类两类用于操作线程通信的方法.
wait():执行该方法的线程对象释放同步锁,JVM把该线程存放到等待池中,等待其他的线程唤醒该线程.
notify:执行该方法的线程唤醒在等待池中等待的任意一个线程,把线程转到锁池中等待.
notifyAll():执行该方法的线程唤醒在等待池中等待的所有的线程,把线程转到锁池中等待.
error:上述方法只能被同步监听锁对象来调用,否则报错IllegalMonitorStateException..
例子🌰:
假设A线程和B线程共同操作一个X对象(同步锁),A,B线程可以通过X对象的wait和notify方法来进行通信,流程如下:
1:当A线程执行同步锁X对象的同步方法时,A线程持有X对象的锁,B线程没有执行机会,B线程在X对象的锁池中等待.
2:A线程在同步方法中执行X.wait()方法时,A线程释放X对象的锁,进入A线程进入X对象的等待池中.
3:在X对象的锁池中等待锁的B线程获取X对象的锁,执行X的另一个同步方法.
4:B线程在同步方法中执行X.notify()方法时,JVM把A线程从X对象的等待池中移动到X对象的锁池中,等待获取锁.
5:B线程执行完同步方法,释放锁.A线程获得锁,继续执行同步方法.
以下为简单的代码:
同步锁对象1
同步锁对象2
消费者线程
生产者线程
测试
第二种情况使用Lock:
lock生产
lock消费
从Java5开始,可以:
1):使用Lock机制取代synchronized代码块和synchronized 方法.
2):使用Condition接口对象的await,signal,signalAll方法取代Object类中的wait,notify,notifyAll方法.
网友评论