我的编程空间,编程开发者的网络收藏夹
学习永远不晚

Java LockSupport与线程中断

短信预约 -IT技能 免费直播动态提醒
省份

北京

  • 北京
  • 上海
  • 天津
  • 重庆
  • 河北
  • 山东
  • 辽宁
  • 黑龙江
  • 吉林
  • 甘肃
  • 青海
  • 河南
  • 江苏
  • 湖北
  • 湖南
  • 江西
  • 浙江
  • 广东
  • 云南
  • 福建
  • 海南
  • 山西
  • 四川
  • 陕西
  • 贵州
  • 安徽
  • 广西
  • 内蒙
  • 西藏
  • 新疆
  • 宁夏
  • 兵团
手机号立即预约

请填写图片验证码后获取短信验证码

看不清楚,换张图片

免费获取短信验证码

Java LockSupport与线程中断

其次

在Java中没有办法立即停止一条线程,然而停止线程却显得尤为重要,如取消一个耗时操作。因此,Java提供了一种用于停止线程的机制——中断。

中断只是一种协作机制,Java没有给中断增加任何语法,中断的过程完全需要程序员自己实现。

若要中断一个线程,你需要手动调用该线程的interrupt方法,该方法也仅仅是将线程对象的中断标识设成true;

接着你需要自己写代码不断地检测当前线程的标识位,如果为true,表示别的线程要求这条线程中断,

此时究竟该做什么需要你自己写代码实现。

每个线程对象中都有一个标识,用于表示线程是否被中断;该标识位为true表示中断,为false表示未中断;通过调用线程对象的interrupt方法将该线程的标识位设为true;可以在别的线程中调用,也可以在自己的线程中调用。

public void interrupt()

实例方法,interrupt()仅仅是设置线程的中断状态为true,不会停止线程

public static boolean interrupted()


静态方法,Thread.interrupted();

判断线程是否被中断,并清除当前中断状态

这个方法做了两件事:

1 返回当前线程的中断状态

2 将当前线程的中断状态设为false

public boolean isInterrupted()

实例方法,

判断当前线程是否被中断(通过检查中断标志位)

如何使用中断标识停止线程?

三种方式

  • 通过一个volatile变量实现
package com.atguigu.juc.senior.test;

import java.util.concurrent.TimeUnit;


public class InterruptDemo{
	private static volatile boolean isStop = false;
	public static void main(String[] args){
        new Thread(() -> {
            while(true) {
                if(isStop) {
                    break;
                }
                System.out.println("-------hello interrupt");
            }
        },"t1").start();

        //暂停几秒钟线程
        try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); }
        isStop = true;
    }

}
  • 通过AtomicBoolean
package com.zzyy.study.test;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;


public class StopThreadDemo{
	
    private final static AtomicBoolean atomicBoolean = new AtomicBoolean(true);

	 public static void main(String[] args) {
        Thread t1 = new Thread(() -> {
            while(atomicBoolean.get()) {
                try { TimeUnit.MILLISECONDS.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); }
                System.out.println("-----hello");
            }
        }, "t1");
        t1.start();

        try { TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { e.printStackTrace(); }

        atomicBoolean.set(false);
    }
}
  • 通过Thread类自带的中断api方法实现

当前线程的中断标识为true,是不是就立刻停止?

具体来说,当对一个线程,调用 interrupt() 时:

① 如果线程处于正常活动状态,那么会将该线程的中断标志设置为 true,仅此而已。

被设置中断标志的线程将继续正常运行,不受影响。所以, interrupt() 并不能真正的中断线程,需要被调用的线程自己进行配合才行。

② 如果线程处于被阻塞状态(例如处于sleep, wait, join 等状态),在别的线程中调用当前线程对象的interrupt方法,那么线程将立即退出被阻塞状态,并抛出一个InterruptedException异常。

需要注意的是Sleep方法抛出InterruptedException异常后,中断标识也被清空置为false, 需要在catch中再次调用 .interrupt( )方法进行中断,否则就会导致无线循环。

LockSupport是什么

LockSupport是用来创建锁和其他同步类的基本线程阻塞原语。

LockSupport中的park() 和 unpark() 的作用分别是阻塞线程和解除阻塞线程

3种让线程等待和唤醒的方法

  • 方式1:使用Object中的wait()方法让线程等待,使用Object中的notify()方法唤醒线程
  • 方式2:使用JUC包中Condition的await()方法让线程等待,使用signal()方法唤醒线程
  • 方式3:LockSupport类可以阻塞当前线程以及唤醒指定被阻塞的线程

Object类中的wait和notify方法实现线程等待和唤醒

static Object objectLock = new Object();

	public static void syncWaitNotify() {
        new Thread(() -> {
            //暂停几秒钟线程
            try { TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { e.printStackTrace(); }
            synchronized (objectLock){
                System.out.println(Thread.currentThread().getName()+"\t"+"---come in");
                try {
                    objectLock.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName()+"\t"+"---被唤醒");
            }
        },"t1").start();

        //暂停几秒钟线程
        try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); }

        new Thread(() -> {
            synchronized (objectLock){
                objectLock.notify();
                System.out.println(Thread.currentThread().getName()+"\t"+"---发出通知");
            }
        },"t2").start();
    }
  • wait和notify方法必须要在同步块或者方法里面,且成对出现使用
  • 先wait后notify才OK

Condition接口中的await后signal方法实现线程的等待和唤醒

public static void lockAwaitSignal() {
        new Thread(() -> {
            //暂停几秒钟线程
            try { TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { 
                e.printStackTrace(); }
            lock.lock();
            try{
                System.out.println(Thread.currentThread().getName()+"\t"+"---come in");
                condition.await();
                System.out.println(Thread.currentThread().getName()+"\t"+"---被唤醒");
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                lock.unlock();
            }
        },"t1").start();

        new Thread(() -> {
            lock.lock();
            try{
                condition.signal();
                System.out.println(Thread.currentThread().getName()+"\t"+"---发出通知");
            }finally {
                lock.unlock();
            }
        },"t2").start();
    }
  • Condtion中的线程等待和唤醒方法之前,需要先获取锁
  • 一定要先await后signal,不要反了

总结:Object和Condition使用的限制条件

  • 线程先要获得并持有锁,必须在锁块(synchronized或lock)中。
  • 必须要先等待后唤醒,线程才能够被唤醒。

LockSupport类中的park等待和unpark唤醒

是什么

LockSupport是用来创建锁和其他同步类的基本线程阻塞原语。

LockSupport类使用了一种名为Permit(许可)的概念来做到阻塞和唤醒线程的功能, 每个线程都有一个许可(permit),permit只有两个值1和零,默认是零。可以把许可看成是一种(0,1)信号量(Semaphore),但与 Semaphore 不同的是,许可的累加上限是1。

主要方法

阻塞 park() /park(Object blocker) 阻塞当前线程/阻塞传入的具体线程

唤醒 unpark(Thread thread) 唤醒处于阻塞状态的指定线程

示例

public static void main(String[] args) {
        Thread t1 = new Thread(() -> {
            System.out.println(Thread.currentThread().getName() + "\t" + "---come in");
            LockSupport.park();
            LockSupport.park();
            System.out.println(Thread.currentThread().getName() + "\t" + "---被唤醒");
        }, "t1");
        t1.start();

        new Thread(() -> {
            LockSupport.unpark(t1);
            try { TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { e.printStackTrace(); }
            LockSupport.unpark(t1);
            System.out.println(Thread.currentThread().getName()+"\t"+"---发出通知");
        },"t2").start();
    }
  • 无锁块要求
  • 之前错误的先唤醒后等待,LockSupport照样支持

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

Java LockSupport与线程中断

下载Word文档到电脑,方便收藏和打印~

下载Word文档

猜你喜欢

Java LockSupport与线程中断

LockSupport类使用了一种名为Permit(许可)的概念来做到阻塞和唤醒线程的功能, 每个线程都有一个许可(permit),permit只有两个值1和零,默认是零。

线程中断 interrupt 和 LockSupport

本文章将要介绍的内容有以下几点,读者朋友也可先自行思考一下相关问题:线程中断 interrupt 方法怎么理解,意思就是线程中断了吗?那当前线程还能继续执行吗?判断线程是否中断的方法有几个,它们之间有什么区别?LockSupport的 pa
2023-06-02

java线程中断 interrupt 和 LockSupport解析

这篇文章主要为大家介绍了java线程中断 interrupt 和 LockSupport示例解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
2023-02-22

java线程中断interrupt和LockSupport的方法是什么

本文小编为大家详细介绍“java线程中断interrupt和LockSupport的方法是什么”,内容详细,步骤清晰,细节处理妥当,希望这篇“java线程中断interrupt和LockSupport的方法是什么”文章能帮助大家解决疑惑,下
2023-07-05

java中线程的中断与终止

线程的中断与终止1、interrupt()、isInterrupted()、interrupted()的作用中断就是线程的一个标识位,它表示一个运行中的线程是否被其他线程调用了中断操作,其他线程可以通过调用线程的interrupt()方法对其进行中断操作,线程
java中线程的中断与终止
2018-10-05

如何在Java中切断线程

如何在Java中切断线程?很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。使用interrupt()切断线程 当一个线程运行时,另一个线程可以调用对应的Thr
2023-05-31

java线程中断之interrupt和stop

interrupt方法当我们调用线程的sleep方法或者join方法时,都可以让某一些线程处于等待状态,调用当前线程的interrupt()方法就可以打断该阻塞状态。interrupt方法不会让线程结束。public void interrupt();// 中
java线程中断之interrupt和stop
2019-09-17

java中isInterrupted()怎么判断线程

这篇文章给大家分享的是有关java中isInterrupted()怎么判断线程的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。Java的优点是什么1. 简单,只需理解基本的概念,就可以编写适合于各种情况的应用程序;
2023-06-14

Java多线程之Interrupt中断线程的示例分析

小编给大家分享一下Java多线程之Interrupt中断线程的示例分析,希望大家阅读完这篇文章之后都有所收获,下面让我们一起去探讨吧!一、测试代码https://gitee.com/zture/spring-test/blob/master
2023-06-15

Java中的线程中断方法怎么用

本篇内容介绍了“Java中的线程中断方法怎么用”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!Java中的线程中断1 线程中断相关方法介绍Ja
2023-07-04

如何处理 Java 线程通信中的中断异常?(Java线程通信怎样处理中断异常)

在Java编程中,线程通信是一个重要的概念,而处理中断异常则是线程通信中常见的问题之一。本文将详细介绍Java线程通信中如何处理中断异常,帮助开发者更好地理解和应用线程通信机制。一、中断异常的概念中断异常是指在多线程环境中,一个线程被另一个线程中断时抛出的异常。当一个
如何处理 Java 线程通信中的中断异常?(Java线程通信怎样处理中断异常)
Java2024-12-14

java中断线程有哪几种方式

本篇内容主要讲解“java中断线程有哪几种方式”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“java中断线程有哪几种方式”吧!中断  中断(Interrupt)一个线程意味着在该线程完成任务之前
2023-06-25

怎么在Java中利用LockSupport类实现并发编程

今天就跟大家聊聊有关怎么在Java中利用LockSupport类实现并发编程,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。一、LockSupport类的属性private stati
2023-06-15

JAVA多线程之中断机制及处理中断的方法

这篇文章主要记录使用interrupt()方法中断线程,以及如何对InterruptedException进行处理,感觉对InterruptedException异常进行处理是一件谨慎且有技巧的活儿,需要的朋友可以参考下
2023-02-13

Java并发编程中LockSupport的用法是怎样的

Java并发编程中LockSupport的用法是怎样的,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。1、什么是LockSupport?LockSupport是用于创建锁和其他同
2023-06-25

热门标签

编程热搜

编程资源站

目录