关于thread.join()的一次错误理解

public static void main(String[] args) throws InterruptedException {

    Thread prevThread = Thread.currentThread();
    for(int i = 0;i<10;i++){
        Thread t = new Thread(new ThreadJoin(prevThread,i));
        t.start();
        prevThread = t;
    }

    TimeUnit.SECONDS.sleep(2);

    System.out.println(Thread.currentThread().getName()+"terminate");

}

private static class ThreadJoin implements Runnable{

    private Thread thread;

    private int num;

    public ThreadJoin(Thread thread, int num) {
        this.thread = thread;
        this.num = num;
    }

    public void run() {
        try {
            thread.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        System.out.println("Thread name:"+Thread.currentThread().getName()+"***********"+num);
    }
}

一个简单的例子，然后当时查看源码，发现thread.join是锁当前对象。

当时发现join锁的是当前对象，而且进行了wait()方法，所以一直认为是main线程.wait()进行无限期等待了，因为一开始就是Main线程调用join()方法的，当时就一直想不通，main线程调用wait()方法把自己阻塞了，怎么可能还能让程序执行下去啊。一直没法理解，然后又跑回去看wait()方法的介绍。发现object.wait()方法，需要当前线程持有object的锁，就等于是synchronized的锁对象是object，然后代码里object.wait()，这里会使当前线程进行进入wait的等待对列，需要另外的线程调用notify或notifyAll方法，唤醒当前线程。所以前面示例代码是thread0的线程调用main.join()。这里的含义其实就是把main线程当成object对象，调用wait方法把当前线程thread0进入一个wait set队列的waiting对列，但是main线程本身不受影响，继续运行直至终结，但是JVM底层在线程执行完之后，会执行notifyAll来唤醒所有被自己阻塞进入waiting队列的线程。

关于thread.join()的一次错误理解

相关推荐