一区二区三区在线-一区二区三区亚洲视频-一区二区三区亚洲-一区二区三区午夜-一区二区三区四区在线视频-一区二区三区四区在线免费观看

服務器之家:專注于服務器技術及軟件下載分享
分類導航

PHP教程|ASP.NET教程|JAVA教程|ASP教程|

服務器之家 - 編程語言 - JAVA教程 - Java并發(fā)編程示例(三):線程中斷

Java并發(fā)編程示例(三):線程中斷

2019-12-06 14:06junjie JAVA教程

這篇文章主要介紹了Java并發(fā)編程示例(三):線程中斷,在本節(jié),我們所開發(fā)的示例程序將會創(chuàng)建一個線程,五秒鐘后,利用中斷機制強制中止這個線程,需要的朋友可以參考下

一個多線程的Java程序,直到所有線程執(zhí)行完成,整個程序才會退出。(需要注意的是,是所有非后臺線程(non-daemon thread)執(zhí)行完成;如果一個線程執(zhí)行了System.exit()方法,程序也會退出。)有時,你想中止一個線程的執(zhí)行,例如你想退出程序,或者你想取消一個正在執(zhí)行的任務等。

Java提供了中斷機制,可以讓我們顯式地中斷我們想中止執(zhí)行的線程。中斷機制的一個特征就是我們可以檢查線程是否已經(jīng)被中斷,進而決定是否響應中止請求。線程也可以忽略中止請求,繼續(xù)執(zhí)行。

在本節(jié),我們所開發(fā)的示例程序將會創(chuàng)建一個線程,五秒鐘后,利用中斷機制強制中止這個線程。

知其然

按照下面步驟所示,完成示例程序。

1.創(chuàng)建一個名為PrimeGenerator的類,并且繼承Thread類。代碼如下:

復制代碼代碼如下:

public class PrimeGenerator extends Thread {


2.重寫run()方法,在方法中添加一個無限循環(huán),在循環(huán)內,通過計算來檢查從1開始的連續(xù)正整數(shù)是否為素數(shù)。如果是,則打印到控制臺。代碼如下:

復制代碼代碼如下:

@Override
public void run() {
    long number = 1L;
    while (true) {
        if (isPrime(number)) {
            System.out.printf("Number %d \tis Prime.", number);
        }


3.在處理一個數(shù)字之后,通過調用isInterrupted()方法來檢查線程是否被中斷。如果該方法返回true,則向控制臺打印一句話,然后中止線程執(zhí)行。代碼如下:

復制代碼代碼如下:


        if (isInterrupted()) {
            System.out.println("The Prime Generator has been Interrupted");
            return;
        }

 

        number++;
    }
}

 

4.實現(xiàn)isPrime()方法,該方法用于判斷參數(shù)是否為素數(shù),如果是則返回true,否則返回false。代碼如下:

復制代碼代碼如下:


/**
 * 判斷參數(shù)是否為素數(shù)
 *
 * @param number 需要判斷的數(shù)字
 * @return
 */
private boolean isPrime(long number) {
    if (number <= 2) {
        return true;
    }

 

    for (int i = 2; i < number; i++) {
        if ((number % i) == 0) {
            return false;
        }
    }

    return true;
}


5.現(xiàn)在,實現(xiàn)示例程序的主類,Main類,同時實現(xiàn)main()方法。代碼如下:

復制代碼代碼如下:

public class Main {
    public static void main(String[] args) {


6.創(chuàng)建一個PrimeGenerator對象,并且啟動該線程。代碼如下:

復制代碼代碼如下:

Thread task = new PrimeGenerator();
task.start();


7.等待五秒鐘,然后中止該線程。代碼如下:

復制代碼代碼如下:


try {
    TimeUnit.SECONDS.sleep(5L);
} catch (InterruptedException e) {
    e.printStackTrace();
}

 

task.interrupt();


8.運行該示例,查看結果。

 

知其所以然

下面的是示例程序執(zhí)行的打印片段。我們從打印出的字符可以看出PrimeGenerator線程是如何打印輸出信息以及當檢測到線程被中斷時,如何中止其執(zhí)行的。

復制代碼代碼如下:

Number 43063    is Prime.
Number 43067    is Prime.
Number 43093    is Prime.
Number 43103    is Prime.
Number 43117    is Prime.
The Prime Generator has been Interrupted

 

Thread有一個布爾型的熟悉,來表明線程是否被中斷。當調用interrupt()方法時,就是將其設置為true。而isInterrupted()方法則是返回該屬性的當前值。

永無止境

Thread還有一個可以檢查線程是否中斷的方法:即靜態(tài)方法interrupted(),可以檢查當前正在執(zhí)行的線程是否被中斷。

 

復制代碼代碼如下:

isInterrupted()方法和interrupted()方法有非常大的不同。前者不會改變線程是否中斷的屬性值;而后者則可以將其值設置為false。interrupted()是一個靜態(tài)方法;平時開發(fā)推薦使用isInterrupted()方法。

 

正如前面所述,線程可以忽略中斷請求而繼續(xù)執(zhí)行。但是,這并不是我們想要的結果。

拿來主義

本文是從 《Java 7 Concurrency Cookbook》 (D瓜哥竊譯為 《Java7并發(fā)示例集》 )翻譯而來,僅作為學習資料使用。沒有授權,不得用于任何商業(yè)行為。

小有所成

示例程序所用的所有代碼的完整版本。

PrimeGenerator類的完整代碼

復制代碼代碼如下:


package com.diguage.books.concurrencycookbook.chapter1.recipe3;

 

/**
 * Date: 2013-09-18
 * Time: 11:53
 */
public class PrimeGenerator extends Thread {

    @Override
    public void run() {
        long number = 1L;
        while (true) {
            if (isPrime(number)) {
                System.out.printf("Number %d \tis Prime.\n", number);
            }

            if (isInterrupted()) {
                System.out.println("The Prime Generator has been Interrupted");
                return;
            }

            number++;
        }
    }

    /**
     * 判斷參數(shù)是否為素數(shù)
     *
     * @param number 需要判斷的數(shù)字
     * @return
     */
    private boolean isPrime(long number) {
        if (number <= 2) {
            return true;
        }

        for (int i = 2; i < number; i++) {
            if ((number % i) == 0) {
                return false;
            }
        }

        return true;
    }
}

 

Main類的完整代碼

 

復制代碼代碼如下:


package com.diguage.books.concurrencycookbook.chapter1.recipe3;

 

import java.util.concurrent.TimeUnit;

/**
 * Date: 2013-09-18
 * Time: 12:33
 */
public class Main {
    public static void main(String[] args) {
        Thread task = new PrimeGenerator();
        task.start();

        try {
            TimeUnit.SECONDS.sleep(5L);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        task.interrupt();
    }
}

 

延伸 · 閱讀

精彩推薦
主站蜘蛛池模板: 久操久操久操 | 欧美成人momandson | 亚洲午夜精品久久久久 | 成3d漫二区三区四区 | 精品久久久久久午夜 | 日韩精品视频在线观看免费 | 亚洲视频第一页 | 男人和女人上床 | 视频一区二区三区在线 | 女同志freelesvoices| 国产香蕉97碰碰在线视频 | 免费精品国产在线观看 | 无码人妻99久久密AV | 精品久久伦理中文字幕 | 国产精品久久久久久久久齐齐 | 亚洲黄色小视频 | 草草视频在线免费观看 | 99久久久久国产精品免费 | v视界影院成片 | 九九99亚洲精品久久久久 | 蜜桃久久久亚洲精品成人 | 久久综合给会久久狠狠狠 | 免费看a视频 | 二区三区视频 | 国产真实乱子伦xxxxchina | 国产成人性毛片aaww | 色狠狠成人综合网 | 亚洲AV蜜桃永久无码精品红樱桃 | 国产精品免费久久久久影院 | 无人区在线观看免费完整版免费 | 扒开腿开嫩苞 | 日韩无砖专区体验区 | 欧美午夜视频一区二区三区 | 我把寡妇日出水好爽 | 欧美亚洲影院 | 大乳一级一区二区三区 | 动漫美女被吸乳羞羞小说 | 日韩手机在线观看 | 楚乔传第二部全60集免费观看 | 青青青手机视频 | 亚洲人成影院午夜网站 |