JUC并发编程之中断机制

简介: 在并发编程中,一个线程的执行可能会被另一个线程打断,这种打断称为"中断"。中断是一种线程间的通信机制,它允许一个线程通知另一个线程,请求它停止当前的工作并进行一些其他的操作。JUC中的中断机制是通过interrupt()方法实现的。

1. 中断机制


在并发编程中,一个线程的执行可能会被另一个线程打断,这种打断称为"中断"。中断是一种线程间的通信机制,它允许一个线程通知另一个线程,请求它停止当前的工作并进行一些其他的操作。JUC中的中断机制是通过interrupt()方法实现的。


1.1 中断原理


中断是通过线程的中断标志位来实现的。每个Java线程都有一个与之关联的boolean类型的中断标志位。当一个线程调用interrupt()方法时,它会将目标线程的中断标志位设置为true,表示该线程已被中断。然后,被中断的线程可以通过检查自己的中断状态来发现中断请求。


1.2  中断方法


1.2.1 interrupt()方法


interrupt()方法是Thread类的实例方法,用于中断当前线程或指定目标线程。它的声明如下:

public void interrupt()

调用interrupt()方法会设置目标线程的中断标志位为true。如果目标线程正在阻塞状态(例如调用了sleep()、wait()、join()等方法),它会立即抛出InterruptedException异常,从阻塞状态返回。在线程在阻塞状态被中断抛出InterruptedException异常后,我们应该恢复中断状态。这是因为异常抛出后,中断标志位会被清除,如果我们希望后续代码能正确检测到中断状态,需要手动再次设置中断标志位。

catch (InterruptedException e) {
    // 恢复中断状态
    Thread.currentThread().interrupt();
}


1.2.2  isInterrupted()方法


isInterrupted()方法是Thread类的实例方法,用于查询当前线程的中断状态。它的声明如下:

public boolean isInterrupted()

调用isInterrupted()方法会返回当前线程的中断标志位。注意,调用该方法不会清除中断标志位。


1.2.3  Thread.interrupted()方法


Thread.interrupted()方法是Thread类的静态方法,用于查询当前线程的中断状态,并清除中断标志位。它的声明如下:

public static boolean interrupted()

调用Thread.interrupted()方法会返回当前线程的中断状态,并将当前线程的中断标志位重置为false。


1.3 正确处理中断


在线程执行的关键位置,我们应该检查线程的中断状态,并根据情况做出相应的响应。例如,在循环中执行某个任务时,我们可以使用isInterrupted()方法检查中断状态,并在发现线程已被中断时,及时终止循环并退出线程。

public void run() {
    while (!Thread.currentThread().isInterrupted()) {
        // 执行任务...
    }
}

有时候我们会将中断标志位传递给其他方法或对象,在处理完中断逻辑后,我们应该清除中断状态,以免影响后续的中断判断。可以使用Thread.interrupted()方法来清除中断标志位。

Thread th = new Thread(() -> {
           while (!Thread.interrupted()){
               System.out.println(Thread.currentThread().getName());
               Thread.currentThread().interrupt();
           }
        }, "th");
        th.start();

1.4 停止中断运行中的线程


1.4.1  volatile


volatile是Java中的关键字,用于声明变量。它的主要作用是保证被volatile修饰的变量对于所有线程是可见的,即每次读取volatile变量都会直接从主内存中获取最新值,而不是使用线程本地的缓存值。在多线程环境下,当一个线程修改了被volatile修饰的变量的值,该值会立即更新到主内存中,并通知其他线程,其他线程读取该变量时会看到最新的值。这样保证了对该变量的修改对所有线程都是可见的。volatile还可以防止指令重排,保证被volatile修饰的变量的读写操作是有序的,不会出现意料之外的结果。


public class Test {
    private static volatile boolean key=false;
    public static void main(String[] args) throws InterruptedException {
             new Thread(()->{
                 while (true){
                     if(key){
                         System.out.println(Thread.currentThread().getName()+ "终止");
                         break;
                     }
                     System.out.println(Thread.currentThread().getName()+" 执行");
                 }
             }).start();
             new Thread(()->{
                 key=true;
             }).start();
    }
}


1.4.2 原子类


原子类是JUC提供的一组用于实现原子操作的工具类,它们在特定操作上保证了原子性。原子类通过CAS(Compare and Swap)算法实现原子操作,CAS是一种乐观锁技术,它能够在不使用锁的情况下实现线程安全的并发操作。


常用的原子类包括:AtomicInteger、AtomicLong、AtomicBoolean等。

public class Test {
    private static AtomicBoolean atomicBoolean=new AtomicBoolean(false);
    public static void main(String[] args) throws InterruptedException {
             new Thread(()->{
                 while (true){
                     if(atomicBoolean.get()){
                         System.out.println(Thread.currentThread().getName()+ "终止");
                         break;
                     }
                     System.out.println(Thread.currentThread().getName()+" 执行");
                 }
             }).start();
             new Thread(()->{
                atomicBoolean.set(true);
             }).start();
    }
}


第三种情况就是使用文章一开始介绍的中断方法。这里省略。

相关文章
|
7月前
|
存储 Java 数据库连接
java多线程之线程通信
java多线程之线程通信
|
7月前
|
Java
JUC并发编程之等待唤醒机制
在JUC(Java Util Concurrent)并发编程中,线程等待唤醒机制是实现线程之间协作和同步的重要手段。这种机制允许一个线程挂起等待某个条件满足后被唤醒,以及另一个线程在满足某个条件后唤醒等待的线程。在Java中,有多种实现线程等待唤醒机制的方式,包括使用Object的wait()和notify()方法、Condition接口以及LockSupport类。
|
7月前
|
缓存 Java 编译器
JUC 并发编程之JMM
Java内存模型是Java虚拟机(JVM)规范中定义的一组规则,用于屏蔽各种硬件和操作系统的内存访问差异,保证多线程情况下程序的正确执行。Java内存模型规定了线程之间如何交互以及线程和内存之间的关系。它主要解决的问题是可见性、原子性和有序性。
|
5月前
|
Java
实现Java多线程中的线程间通信
实现Java多线程中的线程间通信
|
6月前
|
存储 安全 Java
Java并发基础-线程间通信
Java并发基础-线程间通信
22 0
|
7月前
|
缓存 Java 编译器
关于Java并发多线程的一点思考
关于Java并发多线程的一点思考
66 1
|
7月前
|
Java API 调度
【并发编程】Java线程常见方法的使用
【并发编程】Java线程常见方法的使用
|
存储 消息中间件 算法
多线程和并发编程(4)—并发数据结构之BlockingQueue
多线程和并发编程(4)—并发数据结构之BlockingQueue
87 0
|
缓存 监控 安全
JUC并发编程之线程锁(一)
1.ReentrantLock(互斥锁)、2.ReentRantReaderWriterLock(互斥读写锁)、3.StampedLock(无障碍锁)、4.Condition(自定义锁)、5.LockSupport
76 0
【并发编程】线程间的通信
【并发编程】线程间的通信