一起學并發(fā)編程 - 優(yōu)雅關閉

曹金海發(fā)布于2019-08-15 11:57 / 2366人閱讀

摘要：文本將介紹兩種可以優(yōu)雅的終止線程的方式第一種在多線程模式中有一種叫兩步終止的模式可以優(yōu)雅的終止線程，這種模式采用了兩個步驟來終止線程，所以叫兩步終止模式。

Java中原來在Thread中提供了stop()方法來終止線程，但這個方法是不安全的，所以一般不建議使用。文本將介紹兩種可以優(yōu)雅的終止線程的方式...

第一種

在JAVA《Java多線程模式》中有一種叫Two-Phase Termination（兩步終止）的模式可以優(yōu)雅的終止線程，這種模式采用了兩個步驟來終止線程，所以叫兩步終止模式。

先將執(zhí)行標志位isShutdown 設為false，使工作中的線程轉變?yōu)?b>終止處理中的狀態(tài)

真正去執(zhí)行終止操作，這樣的做法可以保證線程的安全性、生命性和響應性。

class Worker extends Thread {
    private volatile boolean isShutdown = true;

    public void shutdown() {
        System.out.println("接收到關閉通知......");
        this.isShutdown = false;
        interrupt();
    }

    @Override
    public void run() {
        while (this.isShutdown) {
            System.out.println("正在工作:" + System.currentTimeMillis());
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                System.out.println("打斷正在工作的線程......");
            }
        }
        System.out.println("銷毀......");
    }
}

public class ThreadClose {
    public static void main(String[] args) throws InterruptedException {
        Worker worker = new Worker();
        worker.start();//開始工作
        Thread.sleep(3 * 1000);
        worker.shutdown();//優(yōu)雅關閉
    }
}

運行日志

正在工作:1505828036769
正在工作:1505828037770
正在工作:1505828038771
接收到關閉通知......
打斷正在工作的線程......
銷毀......

安全性：不會在線程正在執(zhí)行關鍵區(qū)域--Critical Section的時候突然結束掉

生命性：一定會進行終止處理，shutdown()中，會調(diào)用interrupt()，保證即使線程處于sleep或wait狀態(tài)也可以被立即終止

響應性：將isShutdown 設為volatile ，能保證線程收到終止請求后，會盡快開始終止處理。

存在的問題：針對沒有阻塞的情況：設置標志變量，讓線程正常自然死亡，和諧！，但是如果在調(diào)用shutdown發(fā)生阻塞情況呢？

第二種

在《多線程第一章》的時候，介紹過守護線程的作用，那么是不是可以通過開啟守護線程的方式去監(jiān)聽

功能

1.當工作結束就關閉主線程（主線程銷毀守護線程也會跟著一同銷毀）
2.如果任務長時間未完成，停止工作任務，減少開銷

編碼

1.定義主線程與發(fā)送的指令
2.在主線程run方法中創(chuàng)建一個守護線程，用來執(zhí)行我們投遞的任務
3.前面已經(jīng)介紹過join的功能，它可以阻塞主線程，等待子線程完成后主線程繼續(xù)執(zhí)行
4.如果join釋放后，發(fā)送完成指令

private Thread executeService;
private volatile boolean finished = false;
public void execute(Runnable task) {
    executeService = new Thread(() -> {
        Thread runner = new Thread(task);
        runner.setDaemon(true);
        runner.start();
        try {
            runner.join();//前面已經(jīng)說過join與線程了
            finished = true;
        } catch (InterruptedException e) {
            System.out.println("打斷正在工作的線程......");
        }
    });
    executeService.start();
}

5.創(chuàng)建listener(long mills)，監(jiān)聽工作情況
6.監(jiān)聽任務是否完成，如果未完成監(jiān)聽當前是否逾期，逾期打斷線程結束監(jiān)聽

public void listener(long mills) {
    System.out.println("開啟監(jiān)聽......");
    long currentTime = System.currentTimeMillis();
    while (!finished) {
        if ((System.currentTimeMillis() - currentTime) >= mills) {
            System.out.println("工作耗時過長,開始打斷...");
            executeService.interrupt();//打斷線程
            break;
        }
        try {
            executeService.sleep(100L);//每隔100毫秒檢測一次
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

7.測試

public static void main(String[] args) {
    WorkerService service = new WorkerService();
    long start = System.currentTimeMillis();
    service.execute(() -> {
        try {
            Thread.sleep(3 * 1000);// TODO 模擬加載數(shù)據(jù)
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    });
    service.listener(4 * 1000);
    System.out.println("一共耗時：" + (System.currentTimeMillis() - start));
}

listener(4 * 1000) 的運行日志，當任務完成會直接退出，并不會一直占用

開啟監(jiān)聽......
一共耗時：3049

listener(2 * 1000) 的運行日志，當任務超時直接打斷線程，減少資源占用

開啟監(jiān)聽......
工作耗時過長,開始打斷...
一共耗時：2050
打斷正在工作的線程......

- 說點什么

全文代碼：https://gitee.com/battcn/battcn-concurent/tree/master/Chapter1-1/battcn-thread/src/main/java/com/battcn/chapter4

個人QQ：1837307557

battcn開源群（適合新手）：391619659

微信公眾號：battcn（歡迎調(diào)戲）

云服務器 GPU云服務器一起學linux 和一起學python 跟孩子一起學python 與孩子一起學python

文章版權歸作者所有，未經(jīng)允許請勿轉載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉載請注明本文地址：http://systransis.cn/yun/67630.html

一起學并發(fā)編程 - 鉤子函數(shù)（shutdownHook）

摘要：在退出時執(zhí)行必要的挽救措施。在這種情況下，一旦被提供，等待一個進程終止指定的時間。如果進程在該時間限制內(nèi)沒有終止，則通過發(fā)出或中的對等方強制終止進程。所以有可能這是在中途執(zhí)行時發(fā)生的。 shutdownHook是一種特殊的結構，它允許開發(fā)人員插入JVM關閉時執(zhí)行的一段代碼。這種情況在我們需要做特殊清理操作的情況下很有用用途在Jboss，Jetty等容器中都可以看到shutdown...

qpal 2019-08-15 12:06 評論0 收藏0
一起學并發(fā)編程 - 簡易線程池實現(xiàn)

摘要：并且，線程池在某些情況下還能動態(tài)調(diào)整工作線程的數(shù)量，以平衡資源消耗和工作效率。同時線程池還提供了對池中工作線程進行統(tǒng)一的管理的相關方法。開發(fā)中經(jīng)常會遇到各種池（如：連接池，線程池），它們的作用就是為了提高性能及減少開銷，在JDK1.5以后的java.util.concurrent包中內(nèi)置了很多不同使用場景的線程池，為了更好的理解它們，自己手寫一個線程池，加深印象。概述 1.什么是...

Harriet666 2019-08-15 12:09 評論0 收藏0
一起學并發(fā)編程 - 處理異常中止的線程

摘要：在之前，不能為線程單獨設置或指定一個默認的，為了設置，需要繼承并覆寫方法。幸運的是后線程提供了一個方法，用來捕獲并處理因線程中拋出的未知異常，以避免程序終止。在單線程的開發(fā)過程中，通常采用try-catch的方式進行異常捕獲，但是這種方式在多線程環(huán)境中會顯得無能為力，而且還有可能導致一些問題的出現(xiàn)，比如發(fā)生異常的時候不能及時回收系統(tǒng)資源，或者無法及時關閉當前的連接... 概述 Ja...

zacklee 2019-08-15 12:08 評論0 收藏0
一起學并發(fā)編程 - 利用觀察者模式監(jiān)聽線程狀態(tài)

摘要：在前面的文章中介紹過觀察者模式及并發(fā)編程的基礎知識，為了讓大家更好的了解觀察者模式故而特意寫了這篇番外概述在多線程下我們需要知道當前執(zhí)行線程的狀態(tài)是什么比如運行，關閉，異常等狀態(tài)的通知，而且不僅僅是更新當前頁面。在前面的文章中介紹過觀察者模式及并發(fā)編程的基礎知識，為了讓大家更好的了解觀察者模式故而特意寫了這篇番外.. 概述在Java多線程下,我們需要知道當前執(zhí)行線程的狀態(tài)是...

Juven 2019-08-16 10:58 評論0 收藏0
一起學并發(fā)編程 - 線程Join分析

摘要：當時，會進入循環(huán)，系統(tǒng)會判斷主線程是否處于活躍狀態(tài)，如果處于活躍狀態(tài)，主線程就會不停的等待。由于前段時間比較忙，線程這快學習停滯了，只能利用周日的時間來寫寫博客了，多線程Join方法的作用就是把指定的線程加入到當前線程，讓主線程等待子線程結束之后才能繼續(xù)運行，從而完成同步操作介紹 join() 的作用：讓主線程等待子線程結束之后才能繼續(xù)運行，首先先來看下以采集為案例的代碼，統(tǒng)計采...

happen 2019-08-15 11:57 評論0 收藏0