多线程中的join()方法,你真的了解吗?

为何会忽然想到这么一个方法,好像你们工做中不怎么经常使用,可是在平时的面试中只要涉及到多线程中,大多状况下都会问到这个方法,咱们也只是简单的看看面试题说个大概,可是真正的用法你们可能跟我以前同样是比较模糊的。前端

一、先看一段代码,你以为下面的代码的输出顺序是什么?

public static void main(String[] args) throws Exception {        Thread t1 = new Thread(() -> {            try {                Thread.sleep(3000);            } catch (InterruptedException e) {                e.printStackTrace();            }            System.out.println("线程A执行");        });        Thread t2 = new Thread(() -> {            try {                Thread.sleep(2000);            } catch (InterruptedException e) {                e.printStackTrace();            }            System.out.println("线程B执行");        });        t1.start();        t2.start();        System.out.println("我是主线程");    }复制代码

没错,执行结果确实是大部分人猜想的那样,先是主线程执行,而后线程B执行,最后是线程A。面试

咱们来稍微改一下代码bash

public static void main(String[] args) throws Exception {        Thread t1 = new Thread(() -> {            try {                Thread.sleep(3000);            } catch (InterruptedException e) {                e.printStackTrace();            }            System.out.println("线程A执行");        });        Thread t2 = new Thread(() -> {            try {                Thread.sleep(2000);            } catch (InterruptedException e) {                e.printStackTrace();            }            System.out.println("线程B执行");        });        t1.start();        t1.join();        t2.start();        System.out.println("我是主线程");    }复制代码

大家来以为执行顺序会是什么?咱们先来看下答案吧!带着问题咱们来认识join方法,到底干了什么。多线程


二、join()方法

大白话:就是谁调用这个方法,就让调用此方法的线程进入阻塞状态,等待我执行完毕以后,再往下执行;网站

那么咱们再来看上面那段加了join()的代码,首先开启线程A,紧接着线程A调用了join()方法进入阻塞状态,那么线程必须等待线程A执行结束以后再往下执行,线程A执行完毕,线程B开启,进入睡眠,主线程执行,线程B睡眠结束,执行;spa

三、真实场景需求

我上周在作一个爬虫项目,大概是这样的,我要开启多条线程同时爬取不一样网站的信息,进行处理,而后统一返回给前台,这里面要注意的就是,咱们必须等待前面的线程都执行结束,才能返回给前端,那么join()方法就很适合咱们的需求。线程

public static void main(String[] args) throws Exception {        Thread t1 = new Thread(() -> {            for (int i = 1; i < 4; i++) {                System.out.println("线程A : " + i);            }        });        Thread t2 = new Thread(() -> {            for (int i = 1; i < 4; i++) {                System.out.println("线程B : " + i);            }        });        t1.start();        t2.start();        t1.join();        t2.join();        System.out.println("爬取结束");    }复制代码

经过这样,咱们A、B两条线程开启以后开始执行,等待他们所有执行结束以后,再对结果进行统一处理。若是不适用join()方法咱们看看,会是什么状况。3d

还没等线程执行结束,就已经将结果返回回去了,这样明显不知足咱们的需求。code

三、注意,join()的位置可不是乱写的

为何说join()的位置不能乱写,咱们来看两端代码orm

public static void main(String[] args) throws Exception {        Thread t1 = new Thread(() -> {            for (int i = 1; i < 4; i++) {                try {                    Thread.sleep(1000);                } catch (InterruptedException e) {                    e.printStackTrace();                }                System.out.println("线程A : " + i);            }        });        Thread t2 = new Thread(() -> {            for (int i = 1; i < 4; i++) {                try {                    Thread.sleep(1000);                } catch (InterruptedException e) {                    e.printStackTrace();                }                System.out.println("线程B : " + i);            }        });        t1.start();        t2.start();        t1.join();        t2.join();        System.out.println("爬取结束");    }复制代码

public static void main(String[] args) throws Exception {        Thread t1 = new Thread(() -> {            for (int i = 1; i < 4; i++) {                try {                    Thread.sleep(1000);                } catch (InterruptedException e) {                    e.printStackTrace();                }                System.out.println("线程A : " + i);            }        });        Thread t2 = new Thread(() -> {            for (int i = 1; i < 4; i++) {                try {                    Thread.sleep(1000);                } catch (InterruptedException e) {                    e.printStackTrace();                }                System.out.println("线程B : " + i);            }        });        t1.start();        t1.join();        t2.start();        t2.join();        System.out.println("爬取结束");    }复制代码

虽然只是将t1.join()的位置变了一下,可是影响是很是大的,改了位置以后这段代码就变成了了这个意思,t1线程开启,紧接着t1调用了join()方法,那么就必须等待t1执行完毕以后再执行t2,因此此时的多线程代码,其实已经变成了单线程,咱们来看下两段代码的执行结果。

第一段代码结果:


第二段代码结果:

很明显,第一段代码才是咱们想要的多线程结果。

欢迎你们一块儿交流!!!

相关文章
相关标签/搜索