博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Java中interrupt的使用
阅读量:6698 次
发布时间:2019-06-25

本文共 4352 字,大约阅读时间需要 14 分钟。

通常我们会有这样的需求,即停止一个线程。在java的api中有stop、suspend等方法可以达到目的,但由于这些方法在使用上存在不安全性,会带来不好的副作用,不建议被使用。具体原因可以参考。

在本文中,将讨论中断在java中的使用。

中断在java中主要有3个方法,interrupt(),isInterrupted()和interrupted()。

  • interrupt(),在一个线程中调用另一个线程的interrupt()方法,即会向那个线程发出信号——线程中断状态已被设置。至于那个线程何去何从,由具体的代码实现决定。
  • isInterrupted(),用来判断当前线程的中断状态(true or false)。
  • 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");             }else{                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        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;             }else{                System.out.println("not yet interrupted");            }        }    }}

修改代码,在状态判断中如上,添加一个return就okay了。但现实中,我们可能需要做的更通用,不禁又要发出天问,如何中断线程?答案是添加一个开关

public class InterruptionInJava implements Runnable{    private volatile static boolean on = false;    public static void main(String[] args) throws InterruptedException {        Thread testThread = new Thread(new InterruptionInJava(),"InterruptionInJava");        //start thread        testThread.start();        Thread.sleep(1000);        InterruptionInJava.on = 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");            }else{                System.out.println("not yet interrupted");            }        }    }}

这表明是成功中断了的:

这种开关的方式看起来包治百病,但是当遇到线程阻塞时,就会很无奈了,正如下面代码所示:

public class InterruptionInJava implements Runnable{    private volatile static boolean on = false;    public static void main(String[] args) throws InterruptedException {        Thread testThread = new Thread(new InterruptionInJava(),"InterruptionInJava");        //start thread        testThread.start();        Thread.sleep(1000);        InterruptionInJava.on = 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 = false;    public static void main(String[] args) throws InterruptedException {        Thread testThread = new Thread(new InterruptionInJava(),"InterruptionInJava");        //start thread        testThread.start();        Thread.sleep(1000);        InterruptionInJava.on = true;        testThread.interrupt();         System.out.println("main end");     }     @Override    public void run() {        while(!on){            try {                Thread.sleep(10000000);            } catch (InterruptedException e) {                System.out.println("caught exception right now: "+e);            }        }    }

这种情形同样适用io阻塞,通常io阻塞会立即抛出一个SocketException,类似于上面说的InterruptedException。

转载于:https://www.cnblogs.com/zhaoyan001/p/10691697.html

你可能感兴趣的文章
再送一波干货,测试2000线程并发下同时查询1000万条数据库表及索引优化
查看>>
希尔排序
查看>>
[JMX一步步来] 9、基于JBoss来写MBean
查看>>
面向对象的故事~数据底层操作告诉了我们接口,抽象类,继承与多态性的使用~续(TestBase继承ITest是多余的?)...
查看>>
MacOS下MySQL配置
查看>>
jumpserver v0.4.0 基于 CenOS7 的安装详解
查看>>
WF4.0:NativeActivity中的错误处理
查看>>
百度地图定位地址为空
查看>>
第 11 章 Paragraphs
查看>>
Redis在windows下的配置
查看>>
对互联网中常见地图的坐标系探讨
查看>>
44.2. JavaScript Charts
查看>>
C#设计模式(19)——状态者模式(State Pattern)
查看>>
ubuntun安装ssh,并远程链接服务器操作
查看>>
[唐诗]182宫中行乐词(其一)-李白
查看>>
设计模式之禅之六大设计原则-依赖倒置原则
查看>>
ML2 配置 OVS VxLAN - 每天5分钟玩转 OpenStack(146)
查看>>
【转】TCP协议的无消息边界问题
查看>>
SQL Server-数据类型(七)
查看>>
Android Studio项目整合PullToRefresh的问题记录
查看>>