interrupted()和isInterrupted()比较+终止线程的正确方法+暂停线程

interrupted():测试当前线程【运行此方法的当前线程】是否已经是中断状态,执行后具有将状态标志清除为false的功能。

isInterrupted():测试线程对象是否已经是中断状态,但不清除状态标志。

interrupted()的例子:

public static void main(String[] args) {
    try{
        MyThread thread = new MyThread();
        thread.start();
        Thread.sleep(1000);
        thread.interrupt();
        syso(thread.interrupted());
        syso(thread.interrupted());
    }catch(InterruptedException e) {
        e.printStackTrace();
    }
}
//运行结果
false
false

从上可以看出thread.interrupted()执行的是运行当前方法的线程,而不是thread线程,而由于main线程一直没有停止,所以一直是false。

public static void main(String[] args) {
    Thread.currentThread().interrupt();
    syso(Thread.interrupted());
    syso(Thread.interrupted());
}
//运行结果
true
false

从上可以看出Thread.currentTrhead().interrupt()将main线程停止了,所以下面第一个是true状态,而第二个是false状态,就是因为interrupted()方法有清空状态标志的功能。

isInterrupted()的例子:

public static void main(String[] args) {
    try{
        MyThread thread = new MyThread();
        thread.start();
        Thread.sleep(1000);
        thread.interrupt();
        syso(thread.isInterrupted());
        syso(thread.isInterrupted());
    }catch(InterruptedException e) {
        e.printStackTrace();
    }
}
//运行结果
true
true

从上面可以看出isInterrupted()就是线程对象是否中断。

interrupt()并不能真正的结束线程:

public class MyThread extends Thread{
    public void run() {
        super.run();
        for(int i = 0; i < 5; i++) {
            if(this.interrupted()) {
                System.out.println("已经是停止状态了!我要退出了!");
                break;
            }
            System.out.println("i = " + i);
        }
        System.out.println("for之后代码");
    }
}
public class Main {

    public static void main(String[] args) {
        try {
            MyThread thread = new MyThread();
            thread.start();
            Thread.sleep(2000);
            thread.interrupt();
        } catch(InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("结束了");
    }

}

运行结果:

可以发现interrupt()并没有真正终止线程。下面介绍几种可以终止线程的方法:

1.异常法【建议使用】:

if(this.interrupted()) {
                System.out.println("已经是停止状态了!我要退出了!");
    throw new InterruptedException();
                break;
            }

在上面需要正常终止的地方抛出异常即可。

此方法最推荐使用,因为在catch块中还可以将异常向上抛,使线程停止的事件得以传播。

2.在sleep中interrupt():

public class SleepThread extends Thread{
    public void run() {
        super.run();
        try {
            System.out.println("run begin");
            Thread.sleep(200000);
            System.out.println("run end");
        } catch(InterruptedException e) {
            System.out.println("沉睡中停止,进入catch");
            e.printStackTrace();
        }
    }
}
public class SleepMain {

    public static void main(String[] args) {
        try {
            SleepThread thread = new SleepThread();
            thread.start();
            Thread.sleep(200);
            thread.interrupt();
        } catch(InterruptedException e) {
            System.out.println("main catch");
            e.printStackTrace();
        }
        System.out.println("结束了");
    }

}

运行结果:

3.使用作废的stop()方法:

调用stop()方法会强制让线程停止则有可能使一些清理性的工作得不到完成。并且有可能对锁定对象进行了“解锁”,导致数据得不到同步处理,出现数据不一致问题。

4.return法:

public class ReturnThread extends Thread{
    public void run() {
        while(true) {
            if(this.isInterrupted()) {
                System.out.println("停止了!");
                return;
            }
            System.out.println("timer" + System.currentTimeMillis());
        }
    }
}
public class ReturnMain {

    public static void main(String[] args) throws InterruptedException {
        ReturnThread thread = new ReturnThread();
        thread.start();
        Thread.sleep(20);
        thread.interrupt();
    }

}

在需要停止的地方return即可。

 暂停线程所使用的suspend()和resume()已经弃用,这里看一下suspend()方法:

当某个线程的suspend()方法被调用时,该线程会被挂起。如果该线程占有了锁,则它不会释放锁。即,线程在挂起的状态下还持有锁。

public class MyThread extends Thread{
    private long i = 0;
    public void run() {
        while(true) {
            i++;
            //syso是一个同步方法
            System.out.println(i);
        }
    }
}
public class Main {

    public static void main(String[] args) {
        try {
            MyThread thread = new MyThread();
            thread.start();//启动一个线程'thread'
            Thread.sleep(1000);//使当前线程(main线程)睡眠
            thread.suspend();//挂起线程'thread'
            //下面这一行不会执行,因为println一直被占用
            System.out.println("main end!");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

}

下面看一下println()源码:

    public void println(long x) {
        synchronized (this) {
            print(x);
            newLine();
        }
    }

从上可以看出suspend()暂停线程之后不会释放锁。

而在main中调用resume(),可以恢复线程,线程执行完毕就会释放锁。

原文地址:https://www.cnblogs.com/cing/p/8997582.html