join()——化多线程并发执行为顺序执行

多线程并发比较常见,但不少时候一个线程的输入可能很是依赖于另一个线程的输出,此时这个线程就须要等待依赖线程执行完毕再执行。通俗的说,就是合并多个路径为单一路径,变多线程并发为单线程顺序执行。JDK提供了Join()这个Thread类的实例方法来达到这个要求。java

join——英文含义为加入,通俗的说就是将一个线程合并到另外一个线程。可是还有如下几个问题:多线程

哪一个线程加入?并发

加入到哪一个线程?
ide

加入后的效果是啥?函数

经过下面一段代码能够进行验证:spa

public class JoinTest extends Thread {
    private static int i = 0;

    @Override
    public void run() {
        while (i < 100000) {
           i++;
        }
    }

    public static void main(String[] args) throws Exception {
        Thread th = new JoinTest();
        //注意:必须先start,再join
        th.start();
        th.join();
        System.out.println(i);
    }
}

       执行结果为:100000       线程

 验证后能够回答上面三个问题了。code

       哪一个线程加入?——>调用Join()函数的那个对象开启的线程,注意要先开启线程,才能加入start,也就是start()方法要在join()方法前面。本例中是对象

JoinTest

     加入到哪一个线程?——>加入到当前线程,通俗的说在哪一个线程中执行该函数的,就加入哪一个线程。同步

本例中是

main

    加入后的效果?——>阻塞当前线程,直到加入的线程执行完,当前线程继续执行。

    join的本质是让当前线程wait()在调用join方法的那个线程实例的锁上,等到那个线程实例开启的线程跑完,再notify()当前线程继续执行。下面是JDK中join()实现的核心代码片断:

public final synchronized void join(long paramLong)
			throws InterruptedException {
		long l1 = System.currentTimeMillis();
		long l2 = 0L;
		if (paramLong < 0L)
			throw new IllegalArgumentException("timeout value is negative");
	        //过时时间为0
		if (paramLong == 0L)
			while (true) {
                                //isAlive()是一个实例方法,用来判断线程(不是当前main线程,
                                //而是含有该方法的线程实例JoinTest启动的那个线程)是否存活,通俗的说就是run方法有没有跑完
				if (!(isAlive()))
					return;
				//这里是关键,同步方法内调用锁对象的wait()方法阻塞当前线程
				//可能这里会有疑问,阻塞的难道不是JoinTest线程吗?你看,是JoinTest对象里的方法
				//是否是JoinTest线程要看它在不在run方法里面,这个函数在run方法里面吗?显然不是
				super.wait(0L);//被合并线程未结束,当前线程继续等待
			}
		while (isAlive()) {
			long l3 = paramLong - l2;
			if (l3 <= 0L)
				return;
			super.wait(l3);
			l2 = System.currentTimeMillis() - l1;
		}
	}

    以后的流程咱们也能猜到,被合并的线程执行完后,会notify()【其实这里是notifyall()】等待线程继续执行。

相关文章
相关标签/搜索