📜  Java同步-线程中断

📅  最后修改于: 2020-09-27 01:44:07             🧑  作者: Mango

中断线程:

如果任何线程处于睡眠或等待状态(即,调用sleep()或wait()),则在线程上调用interrupt()方法,会抛出InterruptedException中断睡眠或等待状态。如果线程未处于睡眠或等待状态,则调用interrupt()方法将执行正常行为,并且不会中断线程,而是将中断标志设置为true。首先让我们看看Thread类提供的用于中断线程的方法。

Thread类提供的3种中断线程的方法

公共无效中断()公共静态布尔中断()公共布尔isInterrupted()

中断停止工作的线程的示例

在此示例中,在中断线程之后,我们正在传播该线程,因此它将停止工作。如果我们不想停止线程,可以在调用sleep()或wait()方法的地方处理它。首先让我们看一下传播异常的示例。


class TestInterruptingThread1 extends Thread{
public void run(){
try{
Thread.sleep(1000);
System.out.println("task");
}catch(InterruptedException e){
throw new RuntimeException("Thread interrupted..."+e);
}

}

public static void main(String args[]){
TestInterruptingThread1 t1=new TestInterruptingThread1();
t1.start();
try{
t1.interrupt();
}catch(Exception e){System.out.println("Exception handled "+e);}

}
}

中断不停止工作的线程的示例

在此示例中,在中断线程之后,我们将处理异常,因此它将打破休眠状态,但不会停止工作。


class TestInterruptingThread2 extends Thread{
public void run(){
try{
Thread.sleep(1000);
System.out.println("task");
}catch(InterruptedException e){
System.out.println("Exception handled "+e);
}
System.out.println("thread is running...");
}

public static void main(String args[]){
TestInterruptingThread2 t1=new TestInterruptingThread2();
t1.start();

t1.interrupt();

}
}

中断正常运行的线程的示例

如果线程未处于睡眠或等待状态,则调用interrupt()方法会将interrupted标志设置为true,以后Java程序员可以使用该标志来停止线程。


class TestInterruptingThread3 extends Thread{

public void run(){
for(int i=1;i<=5;i++)
System.out.println(i);
}

public static void main(String args[]){
TestInterruptingThread3 t1=new TestInterruptingThread3();
t1.start();

t1.interrupt();

}
}

那isInterrupted和interrupted方法呢?

isInterrupted()方法返回中断标志true或false。静态interrupted()方法返回中断标志,然后将其设置为false(如果为true)。


public class TestInterruptingThread4 extends Thread{

public void run(){
for(int i=1;i<=2;i++){
if(Thread.interrupted()){
System.out.println("code for interrupted thread");
}
else{
System.out.println("code for normal thread");
}

}//end of for loop
}

public static void main(String args[]){

TestInterruptingThread4 t1=new TestInterruptingThread4();
TestInterruptingThread4 t2=new TestInterruptingThread4();

t1.start();
t1.interrupt();

t2.start();

}
}