join方法底层实现

简述

  join方法的主要作用就是同步,它可以使得线程之间的并行执行变为串行执行。在A线程中调用了B线程的join()方法时,表示只有当B线程执行完毕时,A线程才能继续执行。

底层

  首先我们需要知道join方法底层是用wait方法实现的,所以join方法也会释放锁。

wait方法机制

  这里在介绍底层前首先得介绍wait方法的一种机制,当wait方法获取的锁对象是线程实例的时候,线程的任务执行完后会notifyall所有在此线程实例上的wait队列里的线程

public class HighConcurrency {
    public static void main(String[] args) {
        try {
            Thread threadTest = new Thread(){
                public void run(){
                    System.out.println("执行线程中方法");
                    try {
                        Thread.sleep(2000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            };
            threadTest.start();
            synchronized(threadTest){
                threadTest.wait();//当线程终止的时候,会调用线程自身的notifyAll()方法
            }
            System.out.println("执行到了这里");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

  执行结果:

执行线程中方法
执行到了这里

  可以看到并没有线程执行了threadTest.notify但主线程中却被唤醒了,这正是这种机制的体现,当threadTest线程终止的时候会唤醒以

threadTest为锁的wait队列上的线程

join方法底层

  我们再来看join方法的源码

public final synchronized void join(long millis) throws InterruptedException {
        long base = System.currentTimeMillis();
        long now = 0L;
        if (millis < 0L) {
            throw new IllegalArgumentException("timeout value is negative");
        } else {
            if (millis == 0L) {
                while(this.isAlive()) {
                    this.wait(0L);
                }
            } else {
                while(this.isAlive()) {
                    long delay = millis - now;
                    if (delay <= 0L) {
                        break;
                    }

                    this.wait(delay);
                    now = System.currentTimeMillis() - base;
                }
            }

        }
    }

  可以看到join方法底层就是调用了wait方法,我们调用一个线程的join,因为join方法是synchronized修饰的所以会获取该线程实例的锁,然后释放锁进入wait队列,当线程终止的时候也就会唤醒现在等待的线程。合起来也就是join方法的逻辑了。

  我们还可以看到如果有时间的参数,则会wait固定時間。如果被虛假喚醒了,則會檢查獲得鎖的綫程有沒有存貨,若終止了則不再等待。

 

 

 

上一篇:TIME-WAIT


下一篇:Python错误重试