必威体育Betway必威体育官网
当前位置:首页 > IT技术

常见多线程面试题之Thread的join()方法

时间:2019-05-30 07:44:04来源:IT技术作者:seo实验室小编阅读:56次「手机版」
 

thread.join

join简介

join()方法是Thread类中的一个方法,该方法的定义是等待该线程终止。其实就是join()方法将挂起调用线程的执行,直到被调用的对象完成它的执行。这段话难理解,后面我会用实例做讲解。

join实例

现在有T1、T2、T3三个线程,你怎样保证T2T1执行完后执行,T3T2执行完后执行?这个问题是网上很热门的面试题目(这里除了用join之外还有很多其他方法能够实现,只是使用join是最简单方案),下面是实现的代码:

	/**
 	 * 现在有T1、T2、T3三个线程,你怎样保证T2在T1执行完后执行,T3在T2执行完后执行?
 	 * @author RJH
 	 * 2017年11月24日
 	 */
	public class JoinDemo {

		public static void main(String[] args) {
			//初始化线程t1,由于后续有匿名内部类调用这个对象,需要用final修饰
			final Thread t1 = new Thread(new Runnable() {

				@Override
				public void run() {
					System.out.println("t1 is running");
				}
			});
			//初始化线程t2,由于后续有匿名内部类调用这个对象,需要用final修饰
			final Thread t2 = new Thread(new Runnable() {

				@Override
				public void run() {
					try {
						//t1调用join方法,t2会等待t1运行完之后才会开始执行后续代码
						t1.join();
					} catch (InterruptedException e) {
						e.printstacktrace();
					} finally {
						System.out.println("t2 is running");
					}
				}
			});
			//初始化线程t3
			Thread t3 = new Thread(new Runnable() {

				@Override
				public void run() {
					try {
						//t2调用join方法,t3会等待t2运行完之后才会开始执行后续代码
						t2.join();
					} catch (InterruptedException e) {
						e.printStackTrace();
					} finally {
						System.out.println("t3 is running");
					}
				}
			});
			//依次启动3个线程
			t1.start();
			t2.start();
			t3.start();
		}
	}

输出结果

	t1 is running
	t2 is running
	t3 is running

结果分析

t2线程中t2本身就是调用线程,所谓的调用线程是指调用了t.join()方法的线程,而被调用的对象指的是调用join方法的线程对象,即t1。所以这3个线程按照t1->t2->t3的顺序执行了。

join方法源码分析

/**
 *等待该线程终止的时间最长为 millis 毫秒。超时为 0 意味着要一直等下去。
 *millis - 以毫秒为单位的等待时间。
 */
public final synchronized void join(long millis) 
throws InterruptedException {
	//获取启动时的时间戳,用于计算当前时间
	long base = system.currenttimemillis();
   	//当前时间
	long now = 0;

    if (millis < 0) {//等待时间不能小于0则抛出illegalargumentException
        throw new IllegalArgumentException("timeout value is negative");
    }

    if (millis == 0) {//等待时间为0,则无限等待
		//需要注意,如果当前线程未被启动或者终止,则isAlive方法返回false
		//即意味着join方法不会生效
        while (isAlive()) {
            wait(0);
        }
    } else {
		//需要注意,如果当前线程未被启动或者终止,则isAlive方法返回false
		//即意味着join方法不会生效
        while (isAlive()) {
			//计算剩余的等待时间
            long delay = millis - now;
            if (delay <= 0) {//如果剩余的等待时间小于等于0,则终止等待
                break;
            }
			//等待指定时间
            wait(delay);
			//获取当前时间
            now = System.currentTimeMillis() - base;
        }
    }
}

从源码中可以得知,如果要join正常生效,调用join方法的对象必须已经调用了start()方法且并未进入终止状态。

相关阅读

ThreadLocal

Thread原理 https://blog.csdn.net/winwill2012/article/details/71625570jdk1.3之前threadLocal在堆中(全局变量),然后维护一个MAP,M

HandlerThread 的使用及原理

Handy class for starting a new thread that has a looper. The looper can then be used to create handler classes. Note tha

Framework源码分析(三):ActivityThread

在ActivityManagerService这一篇博客中,我们已经了解AMS在Android系统中是管理系统中Activity的重要类,他通过Binder进程间通信的方

Thread的Sleep方法详解,

/* 1.Thread.sleep(毫秒) 2.sleep方法是一个静态方法 3.该方法的作用:阻塞该线程,让给其他线程*/public class fuck4 { public stat

HandlerThread的应用场景

HandlerThread是什么? 它就是一个线程,一个实现了Handler通信机制的线程,也就是说不用我们再去实现Looper的一系列工作了。实现了这

分享到:

栏目导航

推荐阅读

热门阅读