等待/通知机制

原文地址：https://hexige.github.io/blog/2017/09/25/%E7%AD%89%E5%BE%85%E9%80%9A%E7%9F%A5%E6%9C%BA%E5%88%B6/

等待/通知机制

一个线程修改了一个对象的值，而另一个线程感知到了变化，然后进行相应的操作。前者为生产者，后者为消费者。

消费者：

• 获取对象的锁；
• 如果条件不满足，调用对象的wait方法；
• 条件满足则进行对应的操作；

sync(obj){
    whlie(条件不满足){
        obj.wait();
    }
    对应的操作；
}

生产者：

• 获取对象的锁；
• 改变条件；
• 通知所有等待在该对象上的线程；

sync(obj){
    改变条件；
    obj.notifyAll()；
}

Thread.join()

Waits for this thread to die.
如果一个线程A执行了threadB.join(),则表示线程A在threadB终止前一hang住，直到threadB终止，线程A才继续执行后续的操作；

public static void main(String[] args) {
        Thread cur = Thread.currentThread();
        for(int i =0;i<3;i++){
            Thread thread = new Thread(new MRunaable(cur),String.valueOf(i));
            thread.start();
            cur = thread;
        }
    }
    
    static class MRunaable implements Runnable{
        private Thread preThread;
        public MRunaable(Thread preThread) {
            this.preThread = preThread;
        }

        @Override
        public void run() {
            // TODO Auto-generated method stub
            try {
                preThread.join();
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName());
        }
        
    }

此时会按顺序输出线程名，即：等待前一个线程执行完后，才执行下面的输出语句。若不使用preThread.join()方法，输出的线程名不一定按照顺序输出。

join方法源码：

public final void join(long millis) throws InterruptedException {
        synchronized(lock) {
        long base = System.currentTimeMillis();
        long now = 0;

        if (millis < 0) {
            throw new IllegalArgumentException("timeout value is negative");
        }

        if (millis == 0) {
            while (isAlive()) {
                lock.wait(0);
            }
        } else {
            while (isAlive()) {
                long delay = millis - now;
                if (delay <= 0) {
                    break;
                }
                lock.wait(delay);
                now = System.currentTimeMillis() - base;
            }
        }
        }
    }

join方法中的逻辑同等待/通知机制一致.

//条件不满足，等待
while (isAlive()) {
    lock.wait(0);
}
//满足，方法返回