java多线程-线程通信实例详细解读.docx

java多线程-线程通信实例详细解读java多线程-线程通信实例详细解读线程通信的目标是使线程间能够互相发送信号。另一方面，线程通信使线程能够等待其他线程的信号。通过共享对象通信线程间发送信号的一个简单方式是在共享对象的变量里设置信号值。线程A在一个同步块里设置boolean型成员变量hasDataToProcess为true，线程B也在同步块里读取hasDataToProcess这个成员变量。这个简单的例子使用了一个持有信号的对象，并提供了set和check方法:12345678910111213publicclassMySignal{  protectedbooleanhasDataToProcess=false;  publicsynchronizedbooleanhasDataToProcess(){ returnthis.hasDataToProcess; }  publicsynchronizedvoidsetHasDataToProcess(booleanhasData){ this.hasDataToProcess=hasData; } }线程A和B必须获得指向一个MySignal共享实例的引用，以便进行通信。如果它们持有的引用指向不同的MySingal实例，那么彼此将不能检测到对方的信号。需要处理的数据可以存放在一个共享缓存区里，它和MySignal实例是分开存放的。忙等待(BusyWait)准备处理数据的线程B正在等待数据变为可用。换句话说，它在等待线程A的一个信号，这个信号使hasDataToProcess()返回true。线程B运行在一个循环里，以等待这个信号：1234567protectedMySignalsharedSignal=... ... while(!sharedSignal.hasDataToProcess()){ //donothing...busywaiting}wait()，notify()和notifyAll()忙等待没有对运行等待线程的CPU进行有效的利用，除非平均等待时间非常短。否则，让等待线程进入睡眠或者非运行状态更为明智，直到它接收到它等待的信号。Java有一个内建的等待机制来允许线程在等待信号的时候变为非运行状态。java.lang.Object类定义了三个方法，wait()、notify()和notifyAll()来实现这个等待机制。一个线程一旦调用了任意对象的wait()方法，就会变为非运行状态，直到另一个线程调用了同一个对象的notify()方法。为了调用wait()或者notify()，线程必须先获得那个对象的锁。也就是说，线程必须在同步块里调用wait()或者notify()。以下是MySingal的修改版本——使用了wait()和notify()的MyWaitNotify：123456789101112131415161718192021publicclassMonitorObject{} publicclassMyWaitNotify{  MonitorObjectmyMonitorObject=newMonitorObject();  publicvoiddoWait(){ synchronized(myMonitorObject){  try{  myMonitorObject.wait();  }catch(InterruptedExceptione){...} } }  publicvoiddoNotify(){ synchronized(myMonitorObject){  myMonitorObject.notify(); } }}等待线程将调用doWait()，而唤醒线程将调用doNotify()。当一个线程调用一个对象的notify()方法，正在等待该对象的所有线程中将有一个线程被唤醒并允许执行（校注：这个将被唤醒的线程是随机的，不可以指定唤醒哪个线程）。同时也提供了一个notifyAll()方法来唤醒正在等待一个给定对象的所有线程。如你所见，不管是等待线程还是唤醒线程都在同步块里调用wait()和notify()。这是强制性的！一个线程如果没有持有对象锁，将不能调用wait()，notify()或者notifyAll()。否则，会抛出IllegalMonitorStateException异常。（