Java uses the interrupted() function of the Thread class to determine whether the current thread has been interrupted
In Java multi-thread programming, interruption is a common thread communication mechanism. A thread can send an interrupt signal to another thread by calling theinterrupt()
method. The thread that receives the interrupt signal can decide how to respond to the interrupt. TheThread
class in Java provides theinterrupted()
method for determining whether the current thread is interrupted.
interrupted()
method is a static method that returns a Boolean value. When this method is called, it will determine whether the current thread is interrupted and clear the interruption status, that is, reset the interruption status to false. If the thread has been interrupted before calling theinterrupted()
method, theinterrupted()
method will return true; otherwise, it will return false.
The following is a simple example to illustrate the use of theinterrupted()
method:
public class InterruptExample implements Runnable { public void run() { try { System.out.println("线程开始执行"); for (int i = 1; i <= 10; i++) { System.out.println("执行第 " + i + " 次任务"); Thread.sleep(1000); if (Thread.interrupted()) { System.out.println("线程收到中断信号"); throw new InterruptedException(); } } } catch (InterruptedException e) { System.out.println("线程被中断"); } finally { System.out.println("线程结束执行"); } } public static void main(String[] args) { Thread thread = new Thread(new InterruptExample()); thread.start(); try { Thread.sleep(5000); thread.interrupt(); } catch (InterruptedException e) { e.printStackTrace(); } } }
In the above example, we created an implementation ofRunnable
Class of interfaceInterruptExample
. In therun()
method, we use a loop to simulate the tasks performed by the thread. After each task is executed, the thread will be paused for 1 second through theThread.sleep()
method. Before each task is executed, we determine whether the thread is interrupted by calling theThread.interrupted()
method. If so, anInterruptedException
exception is thrown.
In themain()
method, we create a new thread and use thestart()
method to start the thread. Then, the main thread pauses for 5 seconds and calls theinterrupt()
method to send an interrupt signal to the new thread. Through this example, we can observe the following points:
run()
method.InterruptedException
exception.Thread.interrupted()
method, then theThread.interrupted()
method will return true.Thread.interrupted()
method, the thread's interrupt status will be reset to false.By using theinterrupted()
method, we can easily determine whether the current thread is interrupted and handle it accordingly when appropriate. But it should be noted that when a thread is interrupted, it will not stop execution immediately, but will wait until the next interruptible state (such aswait()
,sleep()
,join()
) will stop when it appears. Therefore, when writing multi-threaded code, we should reasonably design the interrupt handling logic in the thread to ensure that the thread can safely stop and release resources.
The above is the detailed content of Java uses the interrupted() function of the Thread class to determine whether the current thread is interrupted.. For more information, please follow other related articles on the PHP Chinese website!