本文转自http://jiangzhengjun.iteye.com/blog/652269
中断线程
线程的thread.interrupt()方法是中断线程,将会设置该线程为中断状态,即设 置为true。线程中断后的结果是死亡、还是等待新的任务或是继续运行至下一步,取决于这个程序本身。线程会不时地检测这个中断标识位,以判断线程是否应 该被中断(中断标识值是否为true)。它并不像stop方法那样会中断一个正在运行的线程。
判断线程是否被中断
判断某个线程是否已被中断,
请使用Thread.currentThread().isInterrupted()方法(因为它将线程中断标识位设置为true后,不会立刻清除中断标识位,即不会将中断标设置为false),
而不要使用thread.interrupted()(该方法调用后会将中断标标位清除,即重新设置为false)方法来判断,下面是线程在循环中时的中断方式:
while(!Thread.currentThread().isInterrupted() && more work to do){ do more work }
如何中断线程
如果一个线程处于了阻塞状态(如线程调用了thread.sleep、 thread.join、thread.wait、1.5中的condition.await、以及可中断的通道上的 I/O 操作方法后可进入阻塞状态),则在线程在检查中断标识时如果发现中断标示为true,则会在这些阻塞方法(sleep、join、wait、1.5中的 condition.await及可中断的通道上的 I/O 操作方法)调用处抛出InterruptedException异常,并且在抛出异常后立即将线程的中断标别位清除,即重新设置为false。抛出异常是为了线程从阻塞状态醒过来,并在结束线程前让程序员有足够的时间来处理中断请求。
注,synchronized在获锁的过程中是不能被中断的,意思是说如果产生了死 锁,则不可能被中断(请参考后面的测试例子)。与synchronized功能相似的reentrantLock.lock()方法也是一样,它也不可中 断的,即如果发生死锁,那么reentrantLock.lock()方法无法终止,如果调用时被阻塞,则它一直阻塞到它获取到锁为止。但是如果调用带超 时的tryLock方法reentrantLock.tryLock(long timeout, TimeUnit unit),那么如果线程在等待时被中断,将抛出一个InterruptedException异常,这是一个非常有用的特性,因为它允许程序打破死锁。 你也可以调用reentrantLock.lockInterruptibly()方法,它就相当于一个超时设为无限的tryLock方法。
没有任何语言方面的需求一个被中断的线程应该终止。中断一个线程只是为了引起该线程的注意,被中断线程可以决定如何应对中断。某些线程非常重要,以至于它 们应该不理会中断,而是在处理完抛出的异常之后继续执行,但是更普遍的情况是,一个线程将把中断看作一个终止请求,这种线程的run方法遵循如下形式
public void run() { try { /* * 不管循环里是否调用过线程阻塞的方法如sleep、join、wait,这里还是需要加上 * !Thread.currentThread().isInterrupted()条件,虽然抛出异常后退出了循环,显 * 得用阻塞的情况下是多余的,但如果调用了阻塞方法但没有阻塞时,这样会更安全、更及时。 */ while (!Thread.currentThread().isInterrupted()&& more work to do) { do more work } } catch (InterruptedException e) { //线程在wait或sleep期间被中断了 } finally { //线程结束前做一些清理工作 } }
上面是while循环在try块里,如果try在while循环里时,应该在catch块里重新设置一下中断标示,因为抛出InterruptedException异常后,中断标示位会自动清除,此时应该这样:
public void run() { while (!Thread.currentThread().isInterrupted()&& more work to do) { try { ... sleep(delay); } catch (InterruptedException e) { Thread.currentThread().interrupt();//重新设置中断标示 } } }
底层中断异常处理方式
另外不要在你的底层代码里捕获InterruptedException异常后不处理,会处理不当,如下:
void mySubTask(){ ... try{ sleep(delay); }catch(InterruptedException e){}//不要这样做 ... }
如果你不知道抛InterruptedException异常后如何处理,那么你有如下好的建议处理方式:
1、在catch子句中,调用 Thread.currentThread.interrupt()来设置中断状态(因为抛出异常后中断标示会被清除),让外界通过判断 Thread.currentThread().isInterrupted()标示来决定是否终止线程还是继续下去,应该这样做:
void mySubTask() { ... try { sleep(delay); } catch (InterruptedException e) { Thread.currentThread().interrupted(); } ... }
2、或者,更好的做法就是,不使用try来捕获这样的异常,让方法直接抛出
void mySubTask() throws InterruptedException { ... sleep(delay); ... }
中断应用
使用中断信号量中断非阻塞状态的线程
中断线程最好的,最受推荐的方式是,使用共享变量(shared variable)发出信号,告诉线程必须停止正在运行的任务。线程必须周期性的核查这一变量,然后有秩序地中止任务
package com.ljq.test; public class ThreadTest extends Thread{ //线程中断信号量 volatile boolean stop=false; public static void main(String[] args) throws Exception { ThreadTest thread=new ThreadTest(); System.out.println("Starting thread..."); thread.start(); Thread.sleep(3000); System.out.println("Asking thread to stop..."); // 设置中断信号量 thread.stop = true; Thread.sleep(3000); System.out.println("Stopping application..."); } @Override public void run() { //每隔一秒检测一下中断信号量 while(!stop){ System.out.println("Thread is running!"); long begin=System.currentTimeMillis(); /** * 使用while循环模拟sleep方法,这里不要使用sleep,否则在阻塞时会抛InterruptedException异常而退出循环, * 这样while检测stop条件就不会执行,失去了意义。 */ while ((System.currentTimeMillis() - begin < 1000)) { } } System.out.println("Thread exiting under request!"); } }
运行结果如下:
使用thread.interrupt()中断非阻塞状态线程
虽然上面案例要求一些编码,但并不难实现。同 时,它给予线程机会进行必要的清理工作。这里需注意一点的是需将共享变量定义成volatile 类型或将对它的一切访问封入同步的块/方法(synchronized blocks/methods)中。上面是中断一个非阻塞状态的线程的常见做法,但对非检测isInterrupted()条件会更简洁:
package com.ljq.test; public class ThreadTest extends Thread{ public static void main(String[] args) throws Exception { ThreadTest thread=new ThreadTest(); System.out.println("Starting thread..."); thread.start(); Thread.sleep(3000); System.out.println("Asking thread to stop..."); // 发出中断请求 thread.interrupt(); Thread.sleep(3000); System.out.println("Stopping application..."); } @Override public void run() { //每隔一秒检测一下中断信号量 while(!Thread.currentThread().isInterrupted()){ System.out.println("Thread is running!"); long begin=System.currentTimeMillis(); /** * 使用while循环模拟sleep方法,这里不要使用sleep,否则在阻塞时会抛InterruptedException异常而退出循环, * 这样while检测stop条件就不会执行,失去了意义。 */ while ((System.currentTimeMillis() - begin < 1000)) { } } System.out.println("Thread exiting under request!"); } }
到目前为止一切顺利!但是,当线程等待某些事件发生而被阻塞,又会发生什么?当然,如果线程被阻塞,它便不能核查共享变量,也就不能停止。这在许多 情况下会发生,例如调用Object.wait()、ServerSocket.accept()和DatagramSocket.receive() 时,这里仅举出一些。
他们都可能永久的阻塞线程。即使发生超时,在超时期满之前持续等待也是不可行和不适当的,所以,要使用某种机制使得线程更早地退出被阻塞的状态。下面就来看一下中断阻塞线程技术。
使用thread.interrupt()中断阻塞状态线程
Thread.interrupt()方法 不会中断一个正在运行的线程。这一方法实际上完成的是,设置线程的中断标示位,在线程受到阻塞的地方(如调用sleep、wait、join等地方)抛出 一个异常InterruptedException,并且中断状态也将被清除,这样线程就得以退出阻塞的状态。下面是具体实现:
package com.ljq.test; public class ThreadTest extends Thread{ public static void main(String[] args) throws Exception { ThreadTest thread=new ThreadTest(); System.out.println("Starting thread..."); thread.start(); Thread.sleep(3000); thread.interrupt();// 等中断信号量设置后再调用 System.out.println("Asking thread to stop..."); Thread.sleep(3000); System.out.println("Stopping application..."); } @Override public void run() { while(!Thread.currentThread().isInterrupted()){ System.out.println("Thread running..."); try { /** * 如果线程阻塞,将不会去检查中断信号量stop变量,所以thread.interrupt() * 会使阻塞线程从阻塞的地方抛出异常,让阻塞线程从阻塞状态逃离出来,并进行异常块进行相应的处理 */ Thread.sleep(1000); //线程阻塞,如果线程收到中断操作信号将抛出异常 } catch (InterruptedException e) { System.out.println("Thread interrupted..."); /** * 如果线程在调用Object.wait()方法,或者该类的join()、sleep()方法 * 过程中受阻,则其中断状态将被清除 */ System.out.println(this.isInterrupted());//false //中不中断由自己决定,如果需要中断线程,则需要重新设置中断位,如果不需要,则不用调用 Thread.currentThread().interrupt(); e.printStackTrace(); } } System.out.println("Thread exiting under request..."); } }
上面案例中一旦Thread.interrupt()被调用,线程便收到一个异常,于是逃离了阻塞状态并确定应该停止。上面我们还可以使用共享信号量来替换!Thread.currentThread().isInterrupted()条件,但不如它简洁.
死锁状态线程无法被中断
下面案例中试着去中断处于死锁状态的两个线程,但这两个线都没有收到任何中断信号(抛出异常),所以interrupt()方法是不能中断死锁线程的,因为锁定的位置根本无法抛出异常
package com.ljq.test; public class ThreadTest extends Thread { public static void main(String args[]) throws Exception { final Object lock1 = new Object(); final Object lock2 = new Object(); Thread thread1 = new Thread() { public void run() { deathLock(lock1, lock2); } }; Thread thread2 = new Thread() { public void run() { // 注意,这里在交换了一下位置 deathLock(lock2, lock1); } }; System.out.println("Starting thread..."); thread1.start(); thread2.start(); Thread.sleep(3000); System.out.println("Interrupting thread..."); thread1.interrupt(); thread2.interrupt(); Thread.sleep(3000); System.out.println("Stopping application..."); } private static void deathLock(Object lock1, Object lock2) { try { synchronized (lock1) { Thread.sleep(10);// 不会在这里死掉 synchronized (lock2) {// 会锁在这里,虽然阻塞了,但不会抛异常 System.out.println(Thread.currentThread()); } } } catch (InterruptedException e) { e.printStackTrace(); System.exit(1); } } }
中断I/O操作
然而,如果线程在I/O操作进行时被阻塞,又会如何?I/O操作可以阻塞线程一段相当长的时间,特别是牵扯到网络应用时。例如,服务器可能需要等待一个请求(request),又或者,一个网络应用程序可能要等待远端主机的响应。
实现此InterruptibleChannel接口的通道是可中断的:如果某个线程在可中断通道上因调用某个阻塞的 I/O 操作(常见的操作一般有这些:serverSocketChannel. accept()、socketChannel.connect、socketChannel.open、socketChannel.read、 socketChannel.write、fileChannel.read、fileChannel.write)而进入阻塞状态,而另一个线程又调用 了该阻塞线程的 interrupt 方法,这将导致该通道被关闭,并且已阻塞线程接将会收到ClosedByInterruptException,并且设置已阻塞线程的中断状态。另外,如 果已设置某个线程的中断状态并且它在通道上调用某个阻塞的 I/O 操作,则该通道将关闭并且该线程立即接收到 ClosedByInterruptException;并仍然设置其中断状态。如果情况是这样,其代码的逻辑和第三个例子中的是一样的,只是异常不同而 已。
如果你正使用通道(channels)(这是在Java 1.4中引入的新的I/O API),那么被阻塞的线程将收到一个ClosedByInterruptException异常。但是,你可能正使用Java1.0之前就存在的传统的 I/O,而且要求更多的工作。既然这样,Thread.interrupt()将不起作用,因为线程将不会退出被阻塞状态。尽管interrupt()被 调用,线程也不会退出被阻塞状态,比如ServerSocket的accept方法根本不抛出异常。
很幸运,Java平台为这种情形提供了一项解决方案,即调用阻塞该线程的套接字的close()方法。在这种情形下,如果线程被I/O操作阻塞,当 调用该套接字的close方法时,该线程在调用accept地方法将接收到一个SocketException(SocketException为 IOException的子异常)异常,这与使用interrupt()方法引起一个InterruptedException异常被抛出非常相似, (注,如果是流因读写阻塞后,调用流的close方法也会被阻塞,根本不能调用,更不会抛IOExcepiton,此种情况下怎样中断?我想可以转换为通 道来操作流可以解决,比如文件通道)。下面是具体实现:
package com.ljq.test; import java.io.IOException; import java.net.ServerSocket; public class ThreadTest extends Thread { volatile ServerSocket socket; public static void main(String args[]) throws Exception { ThreadTest thread = new ThreadTest(); System.out.println("Starting thread..."); thread.start(); Thread.sleep(3000); System.out.println("Asking thread to stop..."); Thread.currentThread().interrupt();// 再调用interrupt方法 thread.socket.close();// 再调用close方法,此句去掉将发生阻塞状态 try { Thread.sleep(3000); } catch (InterruptedException e) { } System.out.println("Stopping application..."); } public void run() { try { socket = new ServerSocket(3036); } catch (IOException e) { System.out.println("Could not create the socket..."); return; } while (!Thread.currentThread().isInterrupted()) { System.out.println("Waiting for connection..."); try { socket.accept(); } catch (IOException e) { System.out.println("accept() failed or interrupted..."); Thread.currentThread().interrupt();// 重新设置中断标示位 } } //判断线程是否被阻塞,如果被阻塞则无法打印此句 System.out.println("Thread exiting under request..."); } }
相关推荐
### JAVA线程深入了解 #### 一、JAVA线程启动方式详解 ##### 1. 利用`Thread`类的子类启动线程 在Java中,可以通过继承`Thread`类来创建一个新的线程。这种方式相对直观,易于理解。具体做法是创建一个`Thread`类...
本教程的压缩包包含了中断线程的源代码实例和详细指导,旨在帮助开发者深入理解和掌握这一核心概念。以下是关于Java中断线程的一些关键知识点: 1. **线程状态**:在Java中,线程有多种状态,包括新建、可运行、...
本文将深入探讨CPU中断如何支撑多线程机制,并解释其工作原理。 #### 二、CPU中断概述 CPU中断是指处理器在执行指令过程中被突然打断的现象。这种打断通常由硬件设备发起,目的是通知CPU发生了某些重要的事件(如...
- **interrupt() 方法**:中断线程,使得线程进入中断状态。 - **volatile 关键字**:保证变量的可见性和有序性。 #### 原理篇 **6. Java内存模型基础知识** - **主内存与工作内存**:主内存存储所有变量副本,...
本文将深入探讨Java多线程中的`join()`方法,以及它在实际开发中的应用。 `join()`方法是Java线程同步的一种机制,主要用于控制线程的执行顺序。在主线程中调用某个子线程的`join()`方法,主线程会等待该子线程执行...
// 超时后中断线程 } ``` 基本数据类型在超时控制中主要体现在计算或比较操作上,例如,我们可以用long类型的变量记录开始时间,然后在超时检查时与当前时间进行比较。反射则允许我们在运行时动态获取类、方法和...
7. **异常处理**:多线程环境下,如何正确处理和传播异常是另一个重要话题,包括线程间的异常传递和中断机制。 8. **线程安全的编程实践**:书中可能会讨论如何编写线程安全的代码,包括避免使用静态变量、合理使用...
### WINCE5.0的中断深入了解 #### 一、总体了解流程 为了深入理解Windows CE 5.0(以下简称WinCE5.0)中的中断处理机制,本节将重点介绍针对2440BSP(Board Support Package)的中断流程。通过对中断流程的详细...
在本话题中,我们将深入探讨线程通信的原理、方法,以及潜在的危险。 首先,线程通信是指在一个进程中,不同的线程之间共享数据和协调执行顺序的过程。这种通信通常涉及两个主要方面:同步和互斥。同步是为了保证...
本实例将深入探讨这些主题,帮助你更好地理解和掌握Java中线程的高级操作。 1. **线程中断**: Java通过`Thread.interrupt()`方法提供线程中断机制。当调用一个线程的`interrupt()`方法时,并不会立即停止该线程,...
9. **中断线程**:Thread类的interrupt()方法可以请求线程中断,但并不会立即停止线程,而是让线程在检查到中断标志后自行决定如何退出。 10. **守护线程(Daemon)**:守护线程是一种特殊的线程,当所有非守护线程...
Java中,`join`方法有类似功能,而`interrupt`方法可以用来中断线程,通常配合`isInterrupted`或`interrupted`检查中断状态。 在实际应用中,线程调度还需要考虑线程同步和互斥问题,以防止数据竞争和死锁。C语言中...
参考文献中的《Java2实用教程》是一本经典的Java学习资料,可能提供了更多关于Java线程和并发编程的深入知识。 总的来说,这个简单的示例展示了如何在Java中使用线程中断来控制并发任务的执行流程,特别是在处理长...
9. **线程中断**:`interrupt()`方法可以标记线程中断状态,线程可以通过检查`isInterrupted()`或`interrupted()`方法来响应中断请求,从而优雅地停止线程执行。 10. **线程局部变量(ThreadLocal)**:为每个线程...
- 终止(Terminated):线程执行完毕或被中断。 4. **线程安全** - volatile关键字:保证多线程环境下变量的可见性和有序性。 - final关键字:确保初始化一次且不可变,有利于线程安全。 - ThreadLocal:为每个...
在Arduino上实现多线程的一种常见方法是使用中断和定时器。例如,描述中提到的“自动条码”可能涉及读取条码传感器,这通常需要中断服务程序来处理。同时,“给步进电机脉冲”则可能需要一个精确的时间序列来控制...
- **中断线程**:通过调用`interrupt()`方法可以请求线程停止执行,但实际停止需要线程内部配合检查`isInterrupted()`或捕获`InterruptedException`。 - **死锁**:当两个或更多线程相互等待对方释放资源而造成的一...
Java的Thread类提供了start()来启动线程,interrupt()来中断线程,但需要注意的是,中断并不一定能立即停止线程,线程需要自行检查并响应中断状态。 另外,可能还会涉及到死锁、活锁和饥饿等并发问题,这些都是多...
"中断线程处理程序-项目开发"是一个专注于解决线程中断问题的方案,它提供了不同于传统方法(如使用`yield()`或`delay(ms)`)的线程切换机制,并且不依赖预分配的堆栈。 传统的多线程编程中,`yield()`函数用于让...