線程間的通訊

1.wait/notify機制

import java.util.ArrayList;
import java.util.List;

public class MyList {

    private static List<String> list = new ArrayList<String>();

    public static void add() {
        list.add("anyString");
    }

    public static int size() {
        return list.size();
    }
}


public class ThreadA extends Thread {

    private Object lock;

    public ThreadA(Object lock) {
        super();
        this.lock = lock;
    }

    @Override
    public void run() {
        try {
            synchronized (lock) {
                if (MyList.size() != 5) {
                    System.out.println("wait begin "
                            + System.currentTimeMillis());
                    lock.wait();
                    System.out.println("wait end  "
                            + System.currentTimeMillis());
                }
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}


public class ThreadB extends Thread {
    private Object lock;

    public ThreadB(Object lock) {
        super();
        this.lock = lock;
    }

    @Override
    public void run() {
        try {
            synchronized (lock) {
                for (int i = 0; i < 10; i++) {
                    MyList.add();
                    if (MyList.size() == 5) {
                        lock.notify();
                        System.out.println("已經發出了通知");
                    }
                    System.out.println("添加了" + (i + 1) + "個元素!");
                    Thread.sleep(1000);
                }
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

public class Run {

    public static void main(String[] args) {

        try {
            Object lock = new Object();

            ThreadA a = new ThreadA(lock);
            a.start();

            Thread.sleep(50);

            ThreadB b = new ThreadB(lock);
            b.start();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

線程A要等待某個條件知足時(list.size()==5)，才執行操做。線程B則向list中添加元素，改變list 的size。

A,B之間如何通訊的呢？也就是說，線程A如何知道 list.size() 已經爲5了呢？

這裏用到了Object類的 wait() 和 notify() 方法。

當條件未知足時(list.size() !=5)，線程A調用wait() 放棄CPU，並進入阻塞狀態。---不像②while輪詢那樣佔用CPU

當條件知足時，線程B調用 notify()通知 線程A，所謂通知線程A，就是喚醒線程A，並讓它進入可運行狀態。

這種方式的一個好處就是CPU的利用率提升了。

可是也有一些缺點：好比，線程B先執行，一會兒添加了5個元素並調用了notify()發送了通知，而此時線程A還執行；當線程A執行並調用wait()時，那它永遠就不可能被喚醒了。由於，線程B已經發了通知了，之後再也不發通知了。這說明：通知過早，會打亂程序的執行邏輯。

2.condition

Condition是被綁定到lock上的，要建立一個Lock的Condition對象必須用newCondition()方法中。在一個lock對象裏面能夠建立多個Condition對象，線程能夠註冊在指定的Condition對象從哪一個中，從而能夠選擇地進行線程通知。

await替代wait；signal替代notify

3.管道

管道只能單向通訊，要實現兩個線程之間互通訊，須要兩個管道流。