Thread类中的join()方法

深碍√TFBOYSˉ_ 2023-06-13 09:25 41阅读 0赞

在很多情况下，主线程创建并启动子线程，如果子线程中要进行大量的耗时运算，主线程将早于子线程结束。这时，如果主线程想等子线程执行完成才结束，比如子线程处理一个数据，主线程想要获得这个数据中的值，就要用到join（）方法了。**方法join()的作用是等待线程对象销毁。**  
join方法的主要作用就是同步，它可以使得线程之间的并行执行变为串行执行。在A线程中调用了B线程的join()方法时，表示只有当B线程执行完毕时，A线程才能继续执行。  
join方法中如果传入参数，则表示这样的意思：如果A线程中调用B线程的join(10)，则表示A线程会等待B线程执行10毫秒，10毫秒过后，A,B线程并行执行。需要注意的是，jdk规定，join(0)的意思不是A线程等待B线程0秒，而是A线程等待B线程无限时间，直到B线程执行完毕，即join(0)等价于join()。(其实join()中调用的是join(0))。  
**join方法必须在线程start方法调用之后调用才有意义。这个也很容易理解：如果一个线程都没有start，那它也就无法同步了。**  
也就是说，t.join()方法阻塞调用此方法的线程(calling thread)，直到线程t完成，此线程再继续；通常用于在main()主线程内，等待其它线程完成再结束main()主线程。  
举例如下：  
**1.不使用join（）方法的情况：**

public static void main(String[] args){ 
        System.out.println("MainThread run start.");
    
        //启动一个子线程
        Thread threadA = new Thread(new Runnable() { 
            @Override
            public void run() { 
                System.out.println("threadA run start.");
                try { 
                    Thread.sleep(1000);
                } catch (Exception e) { 
                    e.printStackTrace();
                }
                System.out.println("threadA run finished.");
            }
        });
        threadA.start();
    
        System.out.println("MainThread join before");
        System.out.println("MainThread run finished.");
    }

**运行结果如下：**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzMzc4OTQ1_size_16_color_FFFFFF_t_70]  
因为上述子线程执行时间相对较长，所以是在主线程执行完毕之后结束。  
**2.使用了join()方法的情况**

public static void main(String[] args){ 
        System.out.println("MainThread run start.");
    
        //启动一个子线程
        Thread threadA = new Thread(new Runnable() { 
            @Override
            public void run() { 
                System.out.println("threadA run start.");
                try { 
                    Thread.sleep(1000);
                } catch (Exception e) { 
                    e.printStackTrace();
                }
                System.out.println("threadA run finished.");
            }
        });
        threadA.start();
    
        System.out.println("MainThread join before");
        try { 
            threadA.join();    //调用join()
        } catch (InterruptedException e) { 
            e.printStackTrace();
        }
        System.out.println("MainThread run finished.");
    }

运行结果如下：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzMzc4OTQ1_size_16_color_FFFFFF_t_70 1]  
对子线程threadA使用了join()方法之后，主线程会等待子线程执行完成之后才往后执行。

join()的原理和作用:  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzMzc4OTQ1_size_16_color_FFFFFF_t_70 2]  
首先join() 是一个synchronized方法， 里面调用了wait()，这个过程的目的是让持有这个同步锁的线程进入等待，那么谁持有了这个同步锁呢？答案是主线程，因为主线程调用了threadA.join()方法，相当于在threadA.join()代码这块写了一个同步代码块，谁去执行了这段代码呢，是主线程，所以主线程被wait()了。然后在子线程threadA执行完毕之后，JVM会调用lock.notify\_all(thread);唤醒持有threadA这个对象锁的线程，也就是主线程，会继续执行。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzMzc4OTQ1_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191115151230279.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzMzc4OTQ1,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzMzc4OTQ1_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20191115151940813.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzMzc4OTQ1,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzMzc4OTQ1_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/2019111515243479.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzMzc4OTQ1,size_16,color_FFFFFF,t_70