快捷導(dǎo)航

Java并發(fā)編程之線程中斷

更新時(shí)間：2021年09月29日 09:02:22 作者：黑夜中的小迷途

這篇文章主要介紹了Java并發(fā)編程線程中斷，java線程中斷是一種線程間的協(xié)作模式，通過設(shè)置線程的中斷標(biāo)志并不能直接終止該線程的運(yùn)行，而是被中斷的線程根據(jù)中斷狀態(tài)自行處理,需要的朋友可以參考一下

void interrupted()方法：中斷線程，例如，當(dāng)線程A運(yùn)行時(shí)，線程B可以調(diào)用線程A的interrupted()方法來設(shè)置線程的中斷標(biāo)志為true并立即返回。設(shè)置標(biāo)志僅僅是為了設(shè)置標(biāo)志，線程A實(shí)際并沒有被中斷，它會繼續(xù)往下執(zhí)行，如果線程A因?yàn)檎{(diào)用了wait()方法，join()方法或者sleep()方法而引起的阻塞掛起，這時(shí)候若線程B調(diào)用線程A的interrupted()方法，線程A回調(diào)用這些方法的地方會拋出InterruptedException異常而返回。
boolean isInterrupted()方法：檢測當(dāng)前線程是否被中斷，如果是返回true，否則返回false。
boolean intertupted()方法：檢測當(dāng)縣線程是否被中斷，如果是返回true，否則返回false。與isInterrupted()不同的是，該方法如果發(fā)現(xiàn)線程被中斷，則會清除中斷標(biāo)志。

package com.heiye.learn1;

import java.util.logging.Logger;

public class InterruptedTest {
    public static void main(String[] args) throws InterruptedException {
        Logger logger=Logger.getLogger(InterruptedTest.class.toString());
        Thread thread=new Thread(new Runnable() {
            @Override
            public void run() {
                //如果當(dāng)前線程被中斷則退出循環(huán)
                while (!Thread.currentThread().isInterrupted()){
                    logger.warning(Thread.currentThread()+"Hello");
                }
            }
        });

        //啟動子線程
        thread.start();
        //主線程休眠1s,以便中斷當(dāng)前讓子線程輸出
        Thread.sleep(1000);
        //中斷子線程
        logger.warning("main thread interrupted thread");
        thread.interrupt();
        //等待子線程執(zhí)行完畢
        thread.join();
        logger.info("main is over");
    }
}

在如上代碼中，子線程thread通過檢查當(dāng)前線程中斷標(biāo)志來控制是否退出循環(huán)，主線程在休眠1s后調(diào)用了thread的interupted()方法設(shè)置了中斷標(biāo)志，所以線程thread退出了循環(huán)。

下面看一種情況，當(dāng)線程為了等待一些特定條件的到來時(shí)候，一般會使用sleep()方法,wait(),join()方法來阻塞掛起當(dāng)前線程。下面看一個(gè)例子:

package com.heiye.learn1;

import java.util.logging.Logger;

public class InterruptedTest2 {
    public static void main(String[] args) throws InterruptedException {
        Logger logger = Logger.getLogger(InterruptedTest.class.toString());
        Thread threadOne = new Thread(new Runnable() {
            @Override
            public void run() {
                logger.info("threadOne begin sleep 2000 seconds");
                try {
                    Thread.sleep(2000000);
                    logger.info("threadOne awaking");
                } catch (InterruptedException e) {
                    logger.warning("threadOne is interrupted while sleeping");
                    return;
                    //e.printStackTrace();
                }
                logger.warning("threadOne-leaving normally")    ;
            }
        });

        threadOne.start();
        //確保子線程進(jìn)入睡眠狀態(tài)
        Thread.sleep(1000);
        //打斷子線程睡眠,讓子線程從sleep返回
        threadOne.interrupt();
        //等待子線程執(zhí)行完畢
        threadOne.join();
        logger.info("main thread is over");
    }
}