Java中interrupt的使⽤
通常我们会有这样的需求，即停⽌⼀个线程。在java的api中有stop、suspend等⽅法可以达到⽬的，但由于这些⽅法在使⽤上存在不安全性，会带来不好的副作⽤，不建议被使⽤。具体原因可以参考。
在本⽂中，将讨论中断在java中的使⽤。
中断在java中主要有3个⽅法，interrupt(),isInterrupted()和interrupted()。
interrupt()，在⼀个线程中调⽤另⼀个线程的interrupt()⽅法，即会向那个线程发出信号——线程中断状态已被设置。⾄于那个线程何去何从，由具体的代码实现决定。
isInterrupted()，⽤来判断当前线程的中断状态(true or fal)。
interrupted()是个Thread的static⽅法，⽤来恢复中断状态，名字起得额 。
接下来，看看具体在代码中如何使⽤。
interrupt()不能中断在运⾏中的线程，它只能改变中断状态⽽已。
public class InterruptionInJava implements Runnable{
public static void main(String[] args) throws InterruptedException {
Thread testThread = new Thread(new InterruptionInJava(),"InterruptionInJava");
//start thread
testThread.start();
Thread.sleep(1000);
//interrupt thread
testThread.interrupt();
System.out.println("main end");
}
@Override
public void run() {
while(true){
if(Thread.currentThread().isInterrupted()){
System.out.println("Yes,I am interruted,but I am still running");
}el{
System.out.println("not yet interrupted");
}
}
}
}
结果显⽰，被中断后，仍旧运⾏，不停打印Yes,I am interruted,but I am still running
那么，如何正确中断？
既然是只能修改中断状态，那么我们应该针对中断状态做些什么。
public class InterruptionInJava implements Runnable{
public static void main(String[] args) throws InterruptedException {
Thread testThread = new Thread(new InterruptionInJava(),"InterruptionInJava");图片英文
//start thread
lily英语首页testThread.start();
// Thread.sleep(1000);
//interrupt thread
testThread.interrupt();
System.out.println("main end");
}
@Override
public void run() {
while(true){
if(Thread.currentThread().isInterrupted()){
System.out.println("Yes,I am interruted,but I am still running");
return;
}el{
System.out.println("not yet interrupted");
}
}
}
ridiculousness}
修改代码，在状态判断中如上，添加⼀个return就okay了。但现实中，我们可能需要做的更通⽤，不禁⼜要发出天问，如何中断线程？答案是添加⼀个开关。
public class InterruptionInJava implements Runnable{
private volatile static boolean on = fal;
public static void main(String[] args) throws InterruptedException {
Thread testThread = new Thread(new InterruptionInJava(),"InterruptionInJava");
//start thread
oustestThread.start();
Thread.sleep(1000);
< = true;
System.out.println("main end");
}
@Override
public void run() {
while(!on){
if(Thread.currentThread().isInterrupted()){
System.out.println("Yes,I am interruted,but I am still running");
}el{
System.out.println("not yet interrupted");
}
}
}
}
会输出类似结果，这表明是成功中断了的：
这种开关的⽅式看起来包治百病，但是当遇到线程阻塞时，就会很⽆奈了，正如下⾯代码所⽰：
public class InterruptionInJava implements Runnable{
private volatile static boolean on = fal;
public static void main(String[] args) throws InterruptedException {
Thread testThread = new Thread(new InterruptionInJava(),"InterruptionInJava");
埃尔维斯 普雷斯利//start thread
testThread.start();
Thread.sleep(1000);
< = true;
System.out.println("main end");
}
@Override
public void run() {
while(!on){
try {
上海哪里有成人英语培训Thread.sleep(10000000);
} catch (InterruptedException e) {
System.out.println("caught exception: "+e);
}
}
}
}
线程被阻塞⽆法被中断。这时候救世主interrupt函数⼜回来了，它可以迅速中断被阻塞的线程，抛出⼀个InterruptedException，把线程从阻塞状态中解救出来,show the code。
public class InterruptionInJava implements Runnable{
private volatile static boolean on = fal;
public static void main(String[] args) throws InterruptedException {
Thread testThread = new Thread(new InterruptionInJava(),"InterruptionInJava");
//start thread
testThread.start();
Thread.sleep(1000);
iu怎么读 = true;
testThread.interrupt();
System.out.println("main end");
}
@Override
public void run() {
slatewhile(!on){
try {
Thread.sleep(10000000);
} catch (InterruptedException e) {
System.out.println("caught exception right now: "+e);
}
}
}
helikon
}
结果截图，达到预期。
pest是什么意思这种情形同样适⽤io阻塞，通常io阻塞会⽴即抛出⼀个SocketException，类似于上⾯说的InterruptedException。
