java线程之间通信<四>

  
  在同步方法中，线程间的通信主要依靠wait（），notify（）,notifyAall（），来实现。

   这三个方法必须在synconized 代码块中使用。
下面这段话引用网上：

引用

  wait()方法使当前线程暂停执行并释放对象锁标志，让其他线程可以进入Synchronized数据块，当前线程被放入对象等待池中。当调用 notify()方法后，将从对象的等待池中移走一个任意的线程并放到锁标志等待池中，只有锁标志等待池中的线程能够获取锁标志；如果锁标志等待池中没有线程，则notify()不起作用。
   notifyAll()则从对象等待池中移走所有等待那个对象的线程并放到锁标志等待池中。

下面用代码测验：

程序主要实现2个线程之间通信，实现线程访问的对象的实例变量在0,1之间交替出现。
代码如下：

package com.xxg.Notify;

public class Model {
	
	 public int number;
	 
	public synchronized void add(){
		
		if(number!=0)
		{
		  try {
			wait();
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}	
		}
		number++;

		System.out.println("【当前线程】==="+Thread.currentThread().getName()+"===="+number+"-----当前对应的对象锁为----"+this);
		notify();
		
	}
public synchronized void decrease(){
		
		if(number==0)
		{
		  try {
			wait();
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}	
		}
		number--;
		
		System.out.println("【当前线程】==="+Thread.currentThread().getName()+"===="+number+"-----当前对应的对象锁为----"+this);
		notify();
		
	}
  
}

//增加变量值线程
package com.xxg.Notify;

public class ThIncrease extends Thread {
	public Model in;
	
	 public ThIncrease(Model in)
	 {
		 this.in = in;
	 }
	public void run() {
	 for(int i=0;i<10;i++)	 
	 {   
		 try {
		Thread.sleep(1000);
	} catch (InterruptedException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	}
		 in.add(); //调用自加方法
	 }
	 }
}

//===========================实现自减线程=========================
package com.xxg.Notify;

public class ThDecrease extends Thread {
	public Model in;
	
	 public ThDecrease(Model in)
	 {
		 this.in = in;
	 }
	public void run() {
	 for(int i=0;i<10;i++)	 
	 {   
		 try {
		Thread.sleep(1000);
	} catch (InterruptedException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	}
		 in.decrease();
	 }
	 }
		 
	}


//==========================测试代码=============================
package com.xxg.Notify;

public class Test {

	
	public static void main(String[] args) {
	
		Model mo = new Model();
		Model mo1 = new Model();
	
		Thread t1 = new ThDecrease(mo);
		Thread t2 = new ThIncrease(mo);
		t1.start();
		t2.start();
		
	}

}
//=========================测试结果==============================

【当前线程】===Thread-1====1-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-0====0-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-1====1-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-0====0-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-1====1-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-0====0-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-1====1-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-0====0-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-1====1-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-0====0-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-1====1-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-0====0-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-1====1-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-0====0-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-1====1-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-0====0-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-1====1-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-0====0-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-1====1-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
【当前线程】===Thread-0====0-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459

通过wait()和notify（）方法实现了线程通信，1，和0交替出现。

注意：如果把测试代码
Thread t1 = new ThDecrease(mo);
Thread t2 = new ThIncrease(mo);
改成
Thread t1 = new ThDecrease(mo);
Thread t2 = new ThIncrease(mo1);
就无法实现线程通信了，测试结果为：
【当前线程】===Thread-1====1-----当前对应的对象锁为----com.xxg.Notify.Model@1bc4459
只出现一条结果，就出现死锁了。
我的理解是这样的不知道对不，还望大神指点下。
理解：由于这里产生了mo,mo1，两个不同的对象锁，那么mo1.notif()方法是不可能去唤醒 mo.wait()等待的线程。简单的说就是不同对象的notify（）和wait（）方法不能互相通信。