问:现在有T1、T2、T3三个线程,你怎样保证T2在T1执行完后执行,T3在T2执行完后执行?
答:要保证T1、T2、T3三个线程顺序执行,可以利用Thread类的join方法。
问:join方法的作用?
答:Thread类中的join方法的主要作用就是同步,它可以使得线程之间的并行执行变为串行执行。当我们调用某个线程的这个方法时,这个方法会挂起调用线程,直到被调用线程结束执行,调用线程才会继续执行。
问:join方法传参和不传参的区别?
答:join方法中如果传入参数,则表示这样的意思:如果A线程中掉用B线程的join(10),则表示A线程会等待B线程执行10毫秒,10毫秒过后,A、B线程并行执行。需要注意的是,jdk规定,join(0)的意思不是A线程等待B线程0秒,而是A线程等待B线程无限时间,直到B线程执行完毕,即join(0)等价于join()。
代码如下
packagetech.luxsun.interview.luxinterviewstarter.thread; /*** @author Lux Sun* @date 2021/4/11*/publicclassJoinDemo { publicstaticvoidmain(String[] args) throwsInterruptedException { Threadthread1=newThreadJoinDemo("Thread-1"); Threadthread2=newThreadJoinDemo("Thread-2"); // join方法可以传递参数, join(10)表示main线程会等待t1线程10毫秒, 10毫秒过去后// main线程和t1线程之间执行顺序由串行执行变为普通的并行执行thread1.start(); thread1.join(10); thread2.start(); } } classThreadJoinDemoextendsThread { publicThreadJoinDemo(Stringname) { super(name); } publicvoidrun() { for (inti=0; i<1000; i++) { System.out.println(this.getName() +": "+i); } } }
运行结果:我们可以发现线程t1还没执行完,线程t2就开始执行了。
……Thread-1: 104Thread-1: 105Thread-2: 4Thread-1: 106Thread-1: 107Thread-1: 108Thread-2: 5Thread-1: 109Thread-1: 110Thread-1: 111Thread-1: 112Thread-2: 6Thread-1: 113Thread-2: 7Thread-2: 8Thread-1: 114……
当使用join()无参方法时:可以看到t2会等到t1执行完毕才开始执行。
……Thread-1: 997Thread-1: 998Thread-1: 999Thread-2: 0Thread-2: 1Thread-2: 2……
问:join与start调用顺序问题
答:join方法必须在线程start方法调用之后调用才有意义。这个也很容易理解:如果一个线程都没有start,那它也就无法同步了。因为执行完start方法才会创建线程。
问:join方法实现原理
答:join方法是通过调用线程的wait方法来达到同步的目的的。例如A线程中调用了B线程的join方法,则相当于在A线程中调用了B线程的wait方法,当B线程执行完(或者到达等待时间),B线程会自动调用自身的notifyAll方法唤醒A线程,从而达到同步的目的。
问:源码分析join方法,isAlive()判断线程是否还活着,即线程是否还未终止。
答:由下面的join方法源码可以看到:
1、如果join方法传参为0的话,则会调用isAlive()方法,一直检测线程是否存活(执行完毕),如果存活就调用wait方法,一直阻塞。
2、如果参数为负数,则直接报错:"timeout value is negative"
3、如果参数大于0,则while里面一直判断线程是否存活,存活的话就一直判断当前线程执行的时间并与计算还需要等待多久时间,最后如果等待时间小于等于0就跳出循环,否则就继续wait
publicfinalsynchronizedvoidjoin(longmillis) throwsInterruptedException { longbase=System.currentTimeMillis(); longnow=0; if (millis<0) { thrownewIllegalArgumentException("timeout value is negative"); } if (millis==0) { while (isAlive()) { wait(0); } } else { while (isAlive()) { longdelay=millis-now; if (delay<=0) { break; } wait(delay); now=System.currentTimeMillis() -base; } } }
问:回归到题目,手写一个确保T1、T2、T3的执行顺序的代码
packagetech.luxsun.interview.luxinterviewstarter.thread; /*** @author Lux Sun* @date 2021/4/11*/publicclassJoinDemo { publicstaticvoidmain(String[] args) throwsInterruptedException { Threadthread1=newThreadJoinDemo("Thread-1"); Threadthread2=newThreadJoinDemo("Thread-2"); Threadthread3=newThreadJoinDemo("Thread-3"); thread1.start(); thread1.join(); thread2.start(); thread2.join(); thread3.start(); thread3.join(); } } classThreadJoinDemoextendsThread { publicThreadJoinDemo(Stringname) { super(name); } publicvoidrun() { for (inti=0; i<3; i++) { System.out.println(this.getName() +": "+i); } } }
执行结果如下所示:的确是顺序执行的。
Thread-1: 0Thread-1: 1Thread-1: 2Thread-2: 0Thread-2: 1Thread-2: 2Thread-3: 0Thread-3: 1Thread-3: 2
也有些同学在刚开始学习的时候会采用如下的方式,再次我也进行验证下结论:
thread1.start(); thread2.start(); thread3.start(); thread1.join(); thread2.join(); thread3.join();
执行结果
Thread-1: 0Thread-3: 0Thread-2: 0Thread-3: 1Thread-1: 1Thread-3: 2Thread-2: 1Thread-1: 2Thread-2: 2
发现并不是按照t1、t2、t3的执行顺序的,所以必须是按照以下顺序
thread1.start(); thread1.join(); thread2.start(); thread2.join(); thread3.start(); thread3.join();