java多线程编程（六）-线程间通信

一：线程通信介绍

　　线程通信是通过主动放弃对资源的使用，而让给其它线程的过程。合理的安排多个线程对同一资源的使用，即设计线程间的通信，可以完成很多复杂的任务。

 

 

二：线程通信实现　　

　　1，java.lang.Object超类

　　　　a，上图为Object类的常用方法，其中提供的notify()，notifyAll()，wait()，wait(long timeout) 和 wait(long timeout,int nanos)五个方法可以实现线程间通信。

　　　　b，五个方法都是被final修饰，所以不能被重写。

　　

 

　　2，notify方法

　　　　notify()使用介绍：Wakes up a single thread that is waiting for this object's monitor.　　　　　　　　　　　　

　　　　notifyAll()使用介绍：Wakes up all threads that are waiting for this object's monitor.

 

 

　　3，wait方法

　　　　wait()使用介绍：Causes the current thread to wait until another thread invokes the notify() or the notifyAll() method for this object.

　　　　wait(long timeout)使用介绍：Causes the current thread to wait until either another thread invokes the notify() or notifyAll() method for this object,or a specified amount of time has elapsed.

　　　　wait(long timeout, int nanos)使用介绍：Causes the current thread to wait until another thread invokes the notify() or the notifyAll() method for this object,or some other thread interrupts the current thread ,or a centain amount of the real time has elapsed.

 

 

　　4，个人总结和附录

　　　　a，wait后的线程只能通过notify方法唤醒，从而重新进入就绪状态。

　　　　b，notify()方法只能唤醒一个在wait的线程，且是随机的。

　　　　c，从使用介绍中的 ‘current thread’,解读wait方法的使用需要使用线程必须拥有目标对象的锁，而notify()中使用介绍是主动唤醒其它线程，所以也必须拥有目标对象的锁才有资格去唤醒其它线程。所以wait()和notify方法的使用线程必须拥有目标对象的锁，即在使用时，wait方法和notify方法必须放在synchronized方法或sysnchronized代码块中。

　　　　d，wait方法是主动放弃锁，使线程进入等待锁，发生等待阻塞。而sleep方法并没有让线程放弃对象的锁。

　　　　

　　　　附录

　　　　　　wake up：唤醒

　　　　　　monitor：监视器，即lock,锁。

　　　　　　causer：导致，引起

　　　　　　invokes：调用

　　　　　　specified time：指定的时间

　　　　　　elapsed：逝去的

 

 

 

 

三：设计案例（1010..案例）

 　　1，基础案例

 　　　　下述案利用合理设计线程间的通信例，实现了1010..的打印。

package com.thread.www;
/**
 * 得到 1010的输出结果
 * @author xiaojia
 *
 */
//目标对象
class NumberHolder {
    private int num = 0;
    //加数
    public synchronized void increaseNum(){
        if(0 != num){
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        num ++;
        System.out.print(num);
        
        notify();
    }
    //减数
    public synchronized void decreaseNum(){
        if(0 == num){
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        num --;
        System.out.print(num);
        notify();
    }
}

//加数线程 和 减数线程
class IncreaseThread extends Thread{
    NumberHolder nholder;
    
    public IncreaseThread(NumberHolder nholder) {
        this.nholder = nholder;
    }
    
    @Override
    public void run() {
        
        for (int i = 0; i < 10; i++) {
            nholder.increaseNum();
        }
    }
}

class DecreaseThread extends Thread{
    NumberHolder nholder;
    
    public DecreaseThread(NumberHolder nholder) {
        this.nholder = nholder;
    }
    
    @Override
    public void run() {
        
        for (int i = 0; i < 10; i++) {
            nholder.decreaseNum();
        }
    }
}

//启动线程
public class Test7线程间的通信1 {

    public static void main(String[] args) {
        NumberHolder nholder = new NumberHolder();
        
        IncreaseThread inTh = new IncreaseThread(nholder);
        DecreaseThread deTh = new DecreaseThread(nholder);
        
        inTh.start();
        deTh.start();
    }

}

 

 　　2，问题案例

　　　　　如果创建多个线程，进行加数和减数，基础案例就得不到1010..有规律的打印了，main方法修改如下：

public class Test8线程间的通信2 {

    public static void main(String[] args) {
        NumberHolder numHolder = new NumberHolder();
        
        IncreaseThread inTh = new IncreaseThread(numHolder);
        DecreaseThread deTh = new DecreaseThread(numHolder);
        inTh.start();
        deTh.start();
        
        IncreaseThread inTh2 = new IncreaseThread(numHolder);
        DecreaseThread deTh2 = new DecreaseThread(numHolder);
        inTh2.start();
        deTh2.start();
    }
}

 

　　3，完整案例

　　问题案例中，由于有四个创建的线程，拥有锁对象的线程唤醒wait的其它三个线程是随机的，因此不能按规律打印1010..。

　　解决办法：将加数和减数方法进入wait的if判断修改为while条件，这样当线程被唤醒后还是要进行进行零和非零的判断，才能加数或减数。

package com.thread.www;

class NumberHolder3 {
    private int num = 0;
    public synchronized void increaseNum(){
        while(num != 0){
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        num ++;
        System.out.print(num+" ");
        
        notify();
    }
    
    public synchronized void decreaseNum(){
        while(num == 0){
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        num --;
        System.out.print(num+" ");
        
        notify();
    }
}

class IncreaseThread3 extends Thread{
    private NumberHolder3 numHolder;
    public IncreaseThread3(NumberHolder3 numHolder) {
        this.numHolder = numHolder;
    }
    @Override
    public void run() {
        for (int i = 0; i < 10; i++) {
            try {
                sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            numHolder.increaseNum();
        }
    }
}

class DecreaseThread3 extends Thread{
    private NumberHolder3 numHolder;
    public DecreaseThread3(NumberHolder3 numHolder) {
        this.numHolder = numHolder;
    }
    @Override
    public void run() {
        for (int i = 0; i < 10; i++) {
            try {
                sleep((long)Math.random()*1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            numHolder.decreaseNum();
        }
    }
}

public class Test9线程间的通信3 {

    public static void main(String[] args) {
        NumberHolder3 numHolder = new NumberHolder3();
        
        IncreaseThread3 inTh = new IncreaseThread3(numHolder);
        DecreaseThread3 deTh = new DecreaseThread3(numHolder);
        inTh.start();
        deTh.start();
        
        IncreaseThread3 inTh3 = new IncreaseThread3(numHolder);
        DecreaseThread3 deTh3 = new DecreaseThread3(numHolder);
        inTh3.start();
        deTh3.start();

    }

}

 

 

 

 

 

 

 

参考资料：https://docs.oracle.com/javase/7/docs/api/java/lang/Object.html#notify()

　　　　　http://www.cnblogs.com/mengdd/archive/2013/02/20/2917956.html

原文路径：http://www.cnblogs.com/xiaojia-new/p/8604606.html