为何会忽然想到这么一个方法,好像你们工做中不怎么经常使用,可是在平时的面试中只要涉及到多线程中,大多状况下都会问到这个方法,咱们也只是简单的看看面试题说个大概,可是真正的用法你们可能跟我以前同样是比较模糊的。前端
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()的代码,首先开启线程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()的位置不能乱写,咱们来看两端代码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,因此此时的多线程代码,其实已经变成了单线程,咱们来看下两段代码的执行结果。
第一段代码结果:
第二段代码结果:
很明显,第一段代码才是咱们想要的多线程结果。
欢迎你们一块儿交流!!!