使用wait/notify实现线程间通信

线程与线程之间不是独立的个体，他们彼此之间都是可以相互通信和协作的。比如有两个线程A和B，线程A做的是不断地对变量i进行累加，B做的通过while循环，当检测到i的值是10000时则打印出来，这样两个线程实现了通信，但是线程B不停地通过while语句轮询机制来检测某一个条件，这样会浪费CPU资源。因此我们需要一种机制来减少CPU的资源浪费而且还可以实现多个线程之间的通信，即“wait/notify”机制。

先看一个等待/通知的例子，当list.size()==5时进行通知。

MyList.java

public class MyList {
private static List list=new ArrayList();
public static void add(){
list.add("ltt");
}
public static int size(){
return list.size();
}
}

ThreadA.java

public class ThreadA extends Thread{
private MyList list;
public ThreadA(MyList list) {
super();
this.list=list;
}
public void run(){
try{
synchronized (list) {
if(list.size()!=5){
System.out.println("开始wait等待");
list.wait();
System.out.println("结束wait等待");
}
}
}catch(InterruptedException e){
e.printStackTrace();
}
}
}

ThreadB.java

public class ThreadB extends Thread{
private MyList list;
public ThreadB(MyList list) {
super();
this.list=list;
}
public void run(){
try{
synchronized (list) {
for(int i=0;i<10;i++){
list.add();
if(list.size()==5){
list.notify();
System.out.println("已经发出通知");
}
System.out.println("添加了"+(i+1)+"个元素");
Thread.sleep(1000);
}
}
}catch(InterruptedException e){
e.printStackTrace();
}
}

Run.java

public class Run {
public static void main(String[] args){
MyList list=new MyList();
ThreadA a=new ThreadA(list);
a.start();
ThreadB b=new ThreadB(list);
b.start();
}
}

结果：



解释：

1.wait()和notify()方法都属于Object类的方法，即每一个Object对象都有这两个方法，这两个方法要执行必须获得该对象的对象级别锁，因此这两个方法只能在同步方法或同步代码块中被调用。

2.wait()方法是将当前线程放到“预执行队列”中，直到接到通知或被终端为止。notify()方法是指从随机挑选一个呈wait状态的线程，对其发出通知。即wait()是使线程停止运行并且释放对象锁，notify()是使停止的线程继续运行的，但需要注意的是notify()发出通知后不会立即释放该对象的锁，需要notify()所在的代码块都执行完毕以后才会释放对象的锁，wait()才会拿到锁才可以执行。只要没有notify()的通知，wait()所在的线程一直等待中。

3.notify()是唤醒一个等待中的线程，notifyAll()是唤醒所有等到中的线程。

4.当interrupt方法遇到wait方法时，会导致线程终止，锁也会被释放。

5.wait(long)是等待某一时间内是否有线程对锁进行唤醒，在这个时间内可以由其他的线程唤醒，如果超过这个时间则会自动唤醒。