Java 多线程 join() 和 interrupt() 方法详解 (源码教程)

发布时间：2018-08-08作者：laosun阅读（2090）

join方法详解：

如果有两个个线程A和B，在A线程中调用B.join()，那么当前线程（A线程）会被挂起，暂停执行。一直等到B执行完毕以后，A线程在继续执行。
如果有两个个线程A和B。在A线程中调用B.join(1000)，那么当前线程（A线程），就会被挂起1000ms.在A挂起的过程当中，B线程会执行。B线程执行了1000ms以后，A线程在继续执行（这个过程就是不管B是否执行完毕，只要到了1000毫秒，A线程就会立马执行，而不关心B线程是否执行完毕）。

看以下代码实例：

package com.sunjs.thread3;

class Sleeper extends Thread {

	public Sleeper(String name) {
		super(name);
		start();//构造函数中启动线程
	}

	@Override
	public void run() {
		try {
			System.out.println(getName() + " 开始执行");
			for (int i = 1; i <= 100; i++) {
				System.out.println(getName() + " = " + ++i + " = "
						+ (isInterrupted() == true ? "要被关闭了" : "我还没有收到关闭通知"));
				if (isInterrupted()) {
					System.out.println("我收到了要停止的通知了");
					throw new InterruptedException();
				}
			}
		} catch (InterruptedException e) {
			System.out.println("我已经暂停了，下一个被join的线程你执行吧");
		}
	}
}

class Joiner extends Thread {

	private Sleeper sleeper;

	public Joiner(String name, Sleeper sleeper) {
		super(name);
		this.sleeper = sleeper;
		start();//启动线程
	}

	@Override
	public void run() {
		//==========================
		//这段代码就是join的主体，如果没有这段代码，那么两个线程启动后，执行顺序将是不可预知的，就是所谓的随机执行。
		//如果加入这段代码就是，sleeper线程必须执行完毕退出后，才能执行当前线程，等待的这段时间称为挂起
		
		try {
			sleeper.join();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		//==========================
		System.out.println(sleeper.getName() + " ‘执行or停止’ 完毕， " + getName()
				+ " 开始执行");
		for (int i = 1; i <= 5; i++) {
			System.out.println(getName() + " " + i);
		}
		System.out.println(getName() + " 执行完毕");
	}
}

public class Joining {

	public static void main(String[] args) {
		Sleeper s1 = new Sleeper("s_1");
		Joiner j1 = new Joiner("j_1", s1);
//		s1.interrupt();
	}

}

输入结果(我删掉了一些重复性的结果)：

s_1 开始执行
s_1 = 2 = 我还没有收到关闭通知
s_1 = 4 = 我还没有收到关闭通知
......
s_1 = 98 = 我还没有收到关闭通知
s_1 = 100 = 我还没有收到关闭通知
s_1 ‘执行or停止’ 完毕， j_1 开始执行
j_1 1
j_1 2
j_1 3
j_1 4
j_1 5
j_1 执行完毕

interrupt 方法详解：

我们从字面意思来看就是中断的意思，其实在java多线程中，这个方法的调用不是立即中断线程，而是通知设置线程你现在是中断停止的状态，状态，状态，状态，重要的事情说三遍，仅仅是给线程一个中断的标志。

我们可以在线程run中打印一下这个值。直接调用 isInterrupted() ，返回值是boolean 类型。如果为true，表示，从某个地方给了当前线程一个要中断的状态。这个时候我们可以自己写程序来进行关闭。如果当前这个线程正在sleep(XXX)。那么就会跑出一个 InterruptedException 异常(我们在任何地方sleep(XX)的时候都需要抓捕一下异常，这个大家都知道吧)。但是有一点需要记住：当程序进入InterruptedException异常块中时，这个状态就会被设置成false，意思就是异常抓捕时将清理这个标志状态，所以在cache子句中，在异常被捕获的时候这个标志状态总是为false。所以我们可以判断这个标志状态来手动关闭线程或者跳出线程。

我们来看个实例（和上边的例子一样，就是最后一句注释放开）：

package com.sunjs.thread3;

class Sleeper extends Thread {

	public Sleeper(String name) {
		super(name);
		start();//构造函数中启动线程
	}

	@Override
	public void run() {
		try {
			System.out.println(getName() + " 开始执行");
			for (int i = 1; i <= 100; i++) {
				System.out.println(getName() + " = " + ++i + " = "
						+ (isInterrupted() == true ? "要被关闭了" : "我还没有收到关闭通知"));
				if (isInterrupted()) {
					System.out.println("我收到了要停止的通知了");
					throw new InterruptedException();
				}
			}
		} catch (InterruptedException e) {
			System.out.println("我已经暂停了，下一个被join的线程你执行吧");
		}
	}
}

class Joiner extends Thread {

	private Sleeper sleeper;

	public Joiner(String name, Sleeper sleeper) {
		super(name);
		this.sleeper = sleeper;
		start();//启动线程
	}

	@Override
	public void run() {
		//==========================
		//这段代码就是join的主体，如果没有这段代码，那么两个线程启动后，执行顺序将是不可预知的，就是所谓的随机执行。
		//如果加入这段代码就是，sleeper线程必须执行完毕退出后，才能执行当前线程，等待的这段时间称为挂起
		
		try {
			sleeper.join();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		//==========================
		System.out.println(sleeper.getName() + " ‘执行or停止’ 完毕， " + getName()
				+ " 开始执行");
		for (int i = 1; i <= 5; i++) {
			System.out.println(getName() + " " + i);
		}
		System.out.println(getName() + " 执行完毕");
	}
}

public class Joining {

	public static void main(String[] args) {
		Sleeper s1 = new Sleeper("s_1");
		Joiner j1 = new Joiner("j_1", s1);
		s1.interrupt();
	}

}

打印结果：

s_1 开始执行
s_1 = 2 = 我还没有收到关闭通知
s_1 = 4 = 我还没有收到关闭通知
s_1 = 6 = 我还没有收到关闭通知
s_1 = 8 = 我还没有收到关闭通知
我收到了要停止的通知了
我已经暂停了，下一个被join的线程你执行吧
s_1 ‘执行or停止’ 完毕， j_1 开始执行
j_1 1
j_1 2
j_1 3
j_1 4
j_1 5
j_1 执行完毕

从上边的打印结果我们可以看出，线程Sleeper在执行到i=8的时候收到了中断的通知，然后我们处理了一下跳出了循环。这个线程就算执行完毕了，紧接着被设置了join的线程开始执行。