文章目录
- 暂停
- 中断
- **阻塞情况下中断,抛出异常后线程恢复非中断状态,即 interrupted = false**
- 调用Thread.interrupted() 方法后线程恢复非中断状态
暂停
Java中线程的暂停是调用 java.lang.Thread 类的 sleep 方法。该方法会使当前正在执行的线程暂停指定的一段时间,如果线程持有锁, sleep 方法结束前并不会释放该锁。
中断
java.lang.Thread类有一个 interrupt 方法,该方法直接对线程调用。当被interrupt的线程正在sleep或wait时,会抛出 InterruptedException 异常。
事实上, interrupt 方法只是改变目标线程的中断状态(interrupt status),而那些会抛出InterruptedException 异常的方法,如wait、sleep、join等,都是在方法内部不断地检查中断状态的值。
- interrupt方法
Thread实例方法:必须由其它线程获取被调用线程的实例后,进行调用。实际上,只是改变了被调用线程的内部中断状态;
源码
public void interrupt() {if (this != Thread.currentThread())checkAccess();synchronized (blockerLock) {Interruptible b = blocker;if (b != null) {interrupt0(); // Just to set the interrupt flagb.interrupt(this);return;}}interrupt0();}
- Thread.interrupted方法
Thread类方法:必须在当前执行线程内调用,该方法返回当前线程的内部中断状态,然后清除中断状态(置为false) ; - isInterrupted方法
Thread实例方法:用来检查指定线程的中断状态。当线程为中断状态时,会返回true;否则返回false。
public class ThreadTest {public static void main(String[] args) throws InterruptedException {StopThread thread = new StopThread();thread.start();Thread.sleep(1000L);thread.interrupt();while (thread.isAlive()) { }thread.print();}private static class StopThread extends Thread {private int x = 0; private int y = 0;@Overridepublic void run() {synchronized (this) {++x;try {Thread.sleep(3000L);} catch (InterruptedException e) {e.printStackTrace();}++y;}}public void print() {System.out.println("x=" + x + " y=" + y);}}
}
底层源码实现
// 核心 interrupt 方法
public void interrupt() {if (this != Thread.currentThread()) // 非本线程,需要检查权限checkAccess();synchronized (blockerLock) {Interruptible b = blocker;if (b != null) {interrupt0(); // 仅仅设置interrupt标志位b.interrupt(this); // 调用如 I/O 操作定义的中断方法return;}}interrupt0();
}
// 静态方法,这个方法有点坑,调用该方法调用后会清除中断状态。
public static boolean interrupted() {return currentThread().isInterrupted(true);
}
// 这个方法不会清除中断状态
public boolean isInterrupted() {return isInterrupted(false);
}
// 上面两个方法会调用这个本地方法,参数代表是否清除中断状态
private native boolean isInterrupted(boolean ClearInterrupted);
interrupt() :
- interrupt 中断操作时,非自身打断需要先检测是否有中断权限,这由jvm的安全机制配置;
- 如果线程处于sleep, wait, join 等状态,那么线程将立即退出被阻塞状态,并抛出一个InterruptedException异常;
- 如果线程处于I/O阻塞状态,将会抛出ClosedByInterruptException(IOException的子类)异常;
- 如果线程在Selector上被阻塞,select方法将立即返回;
- 如果非以上情况,将直接标记 interrupt 状态;
注意:interrupt 操作不会打断所有阻塞,只有上述阻塞情况才在jvm的打断范围内,如处于锁阻塞的线程,不会受 interrupt 中断;
阻塞情况下中断,抛出异常后线程恢复非中断状态,即 interrupted = false
public class ThreadTest {public static void main(String[] args) throws InterruptedException {Thread t = new Thread(new Task("mytask"));t.start();t.interrupt();}static class Task implements Runnable{String name;public Task(String name) {this.name = name;}@Overridepublic void run() {try {Thread.sleep(1000);} catch (InterruptedException e) {System.out.println("thread has been interrupt!");}System.out.println("isInterrupted: " +Thread.currentThread().isInterrupted());System.out.println("task " + name + " is over");}}
}
调用Thread.interrupted() 方法后线程恢复非中断状态
public class ThreadTest {public static void main(String[] args) throws InterruptedException {Thread t = new Thread(new Task("mytask"));t.start();t.interrupt();}static class Task implements Runnable{String name;public Task(String name) {this.name = name;}@Overridepublic void run() {System.out.println("first :" + Thread.interrupted());System.out.println("second:" + Thread.interrupted());System.out.println("task " + name + " is over");}}
}