Java中的Interrupt使用

初心

用interrupt中断程序

初步实现

public class InterruptionInJava implements Runnable{    @Override    public void run() {        while (true) {            if (Thread.currentThread().isInterrupted()) {                System.out.println("Yes!!  I'm Interupted,  but I'm still running");            } else {            }        }//        System.out.println("Oh, myGod!");    }    public static void main(String[] args) {        Thread thread = new Thread(new InterruptionInJava(), "testThread");        thread.start();        try {            Thread.sleep(1000);        } catch (InterruptedException e) {        }        System.out.println("Begin Interupt...");        thread.interrupt();        System.out.println("End Interupt...");    }}

输出

Yes!!  I'm Interupted,  but I'm still runningYes!!  I'm Interupted,  but I'm still runningYes!!  I'm Interupted,  but I'm still runningYes!!  I'm Interupted,  but I'm still runningYes!!  I'm Interupted,  but I'm still runningYes!!  I'm Interupted,  but I'm still runningYes!!  I'm Interupted,  but I'm still running.....

问题：虽然是被中断状态，但实际并未中断

interrupt说明

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

interrupt()，在一个线程中调用另一个线程的interrupt()方法，即会向那个线程发出信号——线程中断状态已被设置。至于那个线程何去何从，由具体的代码实现决定。
isInterrupted()，用来判断当前线程的中断状态(true or false)。
interrupted()是个Thread的static方法，用来恢复中断状态（！！！）

解决不中断问题

处于被中断状态时，return 或 bread 中断线程

public class InterruptionInJava implements Runnable{    @Override    public void run() {        while (true) {            if (Thread.currentThread().isInterrupted()) {                System.out.println("Yes!!  I'm Interupted,  but I'm still running");                return;            } else {            }        }    }    public static void main(String[] args) {        Thread thread = new Thread(new InterruptionInJava(), "testThread");        thread.start();        try {            Thread.sleep(1000);        } catch (InterruptedException e) {        }        System.out.println("Begin Interupt...");        thread.interrupt();        System.out.println("End Interupt...");    }}

View Code

等价开关

public class InterruptionInJava2 implements Runnable{    private volatile static boolean on = false;    @Override    public void run() {        while (!on) {            try {                System.out.println("begin Sleep");                Thread.sleep(10000000);                System.out.println("end Sleep");            } catch (InterruptedException e) {                e.printStackTrace();            }            System.out.println("Oh, myGod!");        }    }    public static void main(String[] args) {        Thread thread = new Thread(new InterruptionInJava2(), "testThread");        thread.start();        try {            System.out.println("main Begin sleep");            Thread.sleep(5000);            System.out.println("main End sleep");        } catch (InterruptedException e) {        }        InterruptionInJava2.on = true;    }}

使用静态变量on

但是在run方法中Thread.sleep(10000000)，?何时结束？

开关中断解决方案

public class InterruptionInJava2 implements Runnable{    private volatile static boolean on = false;    @Override    public void run() {        while (!on) {            try {                System.out.println("begin Sleep");                Thread.sleep(10000000);                System.out.println("end Sleep");            } catch (InterruptedException e) {                e.printStackTrace();            }            System.out.println("Oh, myGod!");        }    }    public static void main(String[] args) {        Thread thread = new Thread(new InterruptionInJava2(), "testThread");        thread.start();        try {            System.out.println("main Begin sleep");            Thread.sleep(5000);            System.out.println("main End sleep");        } catch (InterruptedException e) {        }        InterruptionInJava2.on = true;        System.out.println("Begin Interupt...");        thread.interrupt();        System.out.println("End Interupt...");    }}

输出

begin Sleepmain Begin sleepmain End sleepBegin Interupt...End Interupt...java.lang.InterruptedException: sleep interruptedat java.lang.Thread.sleep(Native Method)at com.jihite.templet.JavaBase.InterruptionInJava2.run(InterruptionInJava2.java:11)at java.lang.Thread.run(Thread.java:748)Oh, myGod!Process finished with exit code 0

参考

https://www.cnblogs.com/jenkov/p/juc_interrupt.html　　

文章转载于:https://www.cnblogs.com/kaituorensheng/p/10644267.html

原著是一个有趣的人,若有侵权,请通知删除

本博客所有文章如无特别注明均为原创。
复制或转载请以超链接形式注明转自起风了，原文地址《Java中的Interrupt使用》