欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

<abbr id="9rxz4"></abbr>

<menuitem id="9rxz4"></menuitem>

Java并發(fā)編程示例(十)：線程組

更新時(shí)間：2014年12月05日 11:21:28 投稿：junjie

這篇文章主要介紹了Java并發(fā)編程示例(十)：線程組,Java提供了ThreadGroup類來控制一個(gè)線程組,一個(gè)線程組可以通過線程對象來創(chuàng)建,也可以由其他線程組來創(chuàng)建,生成一個(gè)樹形結(jié)構(gòu)的線程,需要的朋友可以參考下

對線程分組是Java并發(fā)API提供的一個(gè)有趣功能。我們可以將一組線程看成一個(gè)獨(dú)立單元，并且可以隨意操縱線程組中的線程對象。比如，可以控制一組線程來運(yùn)行同樣的任務(wù)，無需關(guān)心有多少線程還在運(yùn)行，還可以使用一次中斷調(diào)用中斷所有線程的執(zhí)行。

Java提供了ThreadGroup類來控制一個(gè)線程組。一個(gè)線程組可以通過線程對象來創(chuàng)建，也可以由其他線程組來創(chuàng)建，生成一個(gè)樹形結(jié)構(gòu)的線程。

根據(jù)《Effective Java》的說明，不再建議使用ThreadGroup。建議使用Executor。

——D瓜哥特此說明。

在本節(jié)，我們就使用ThreadGroup來開發(fā)一個(gè)簡單的示例。我們將創(chuàng)建十個(gè)休眠時(shí)間不等的線程（比如模擬搜索），當(dāng)其中一個(gè)完成時(shí)，中斷其余線程。

知其然

按照下面所示步驟，完成示例代碼。

1.創(chuàng)建一個(gè)名為Result的類，用于存儲第一個(gè)完成任務(wù)的線程的名字。聲明一個(gè)String類型的私有變量，name，同時(shí)生成Setter/Getter方法。代碼如下：

復(fù)制代碼代碼如下:

public class Result {
private String name;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
}

2.創(chuàng)建一個(gè)名為SearchTask的類，并實(shí)現(xiàn)Runnable接口。代碼如下：

復(fù)制代碼代碼如下:

public class SearchTask implements Runnable {

3.聲明一個(gè)Result類型的私有變量，并通過構(gòu)造函數(shù)來實(shí)例化該變量。代碼如下：

復(fù)制代碼代碼如下:

private Result result;

public SearchTask(Result result) {
this.result = result;
}

4.實(shí)現(xiàn)run()方法，在其中調(diào)用doTask()方法，來等待完成或被中斷。該方法還向控制臺打印信息來顯示線程的開始、結(jié)束或者中斷。代碼如下：

復(fù)制代碼代碼如下:

@Override

public void run() {

    String name = Thread.currentThread().getName();

    System.out.printf("Thread %s: Start\n", name);

    try {

        doTask();

        result.setName(name);

    } catch (InterruptedException e) {

        System.out.printf("Thread %s: Interrupted\n", name);

        return;

    }

    System.out.printf("Thread %s: End\n", name);

}

5.實(shí)現(xiàn)doTask()方法，該方法將創(chuàng)建一個(gè)Random對象，然后使用該對象生成一個(gè)隨機(jī)數(shù)，來調(diào)節(jié)線程休眠的時(shí)間。代碼如下：

復(fù)制代碼代碼如下:

// 模擬搜索

private void doTask() throws InterruptedException {

    Random random = new Random(new Date().getTime());

    int value = (int) (random.nextDouble() * 100);

    System.out.printf("Thread %s: %d\n",

            Thread.currentThread().getName(), value);

    TimeUnit.SECONDS.sleep(value);

}

6.創(chuàng)建示例程序的主類，Main，并實(shí)現(xiàn)main()方法。代碼如下：

復(fù)制代碼代碼如下:

public class Main {

    public static void main(String[] args) {

7.創(chuàng)建一個(gè)名稱為Searcher的ThreadGroup對象。代碼如下：

復(fù)制代碼代碼如下:

ThreadGroup threadGroup = new ThreadGroup("Searcher");

8.然后，創(chuàng)建一個(gè)Result對象和SearchTask對象。代碼如下：

復(fù)制代碼代碼如下:

Result result = new Result();

SearchTask searchTask = new SearchTask(result);

9.SearchTask對象使用創(chuàng)建十個(gè)Thread對象，并且創(chuàng)建Thread對象時(shí)，將ThreadGroup對象作為第一個(gè)參數(shù)，傳遞給Thread類的構(gòu)造函數(shù)。代碼如下：

復(fù)制代碼代碼如下:

for (int i = 0; i < 5; i++) {

    Thread thread = new Thread(threadGroup, searchTask);

    thread.start();

    try {

        TimeUnit.SECONDS.sleep(1);

    } catch (InterruptedException e) {

        e.printStackTrace();

    }

}

10.使用list()方法將ThreadGroup對象的信息打印出來。代碼如下：

復(fù)制代碼代碼如下:

System.out.printf("Number of Threads: %d\n", threadGroup.activeCount());

System.out.println("Information about the Thread Group");

threadGroup.list();

11.使用activeCount()和enumerate()來獲取ThreadGroup對象中的活躍線程數(shù)并將其復(fù)制到一個(gè)線程數(shù)組中。使用get*()方法，獲取線程的名稱和狀態(tài)。代碼如下：

復(fù)制代碼代碼如下:

Thread[] threads = new Thread[threadGroup.activeCount()];

threadGroup.enumerate(threads);

for (int i = 0; i < threadGroup.activeCount(); i++) {

    System.out.printf("Thread %s: %s\n", threads[i].getName(),

            threads[i].getState());

}

12.調(diào)用waitFinish()方法，等待ThreadGroup對象中的其中一個(gè)線程完成任務(wù)。稍后實(shí)現(xiàn)該方法。代碼如下：

復(fù)制代碼代碼如下:

waitFinish(threadGroup);

13.使用interrupt()方法，中斷線程組中其他線程。代碼如下：

復(fù)制代碼代碼如下:

threadGroup.interrupt();

14.實(shí)現(xiàn)waitFinish()方法，使用activeCount()方法控制線程的執(zhí)行結(jié)果。代碼如下：

復(fù)制代碼代碼如下:

// 等待任務(wù)完成

private static void waitFinish(ThreadGroup threadGroup) {

    while (threadGroup.activeCount() > 9) {

        try {

            TimeUnit.SECONDS.sleep(1);

        } catch (InterruptedException e) {

            e.printStackTrace();

        }

    }

}

15.運(yùn)行程序，查看執(zhí)行效果。

知其所以然

下面是程序執(zhí)行的結(jié)果。你將看到list()方法的輸出，各個(gè)線程的狀態(tài)等。

復(fù)制代碼代碼如下:

Thread Thread-0: Start

Thread Thread-0: 52

Thread Thread-1: Start

Thread Thread-1: 41

Thread Thread-2: Start

Thread Thread-2: 69

Thread Thread-3: Start

Thread Thread-3: 60

Thread Thread-4: Start

Thread Thread-4: 88

Number of Threads: 5

Information about the Thread Group

java.lang.ThreadGroup[name=Searcher,maxpri=10]

    Thread[Thread-0,5,Searcher]

    Thread[Thread-1,5,Searcher]

    Thread[Thread-2,5,Searcher]

    Thread[Thread-3,5,Searcher]

    Thread[Thread-4,5,Searcher]

Thread Thread-0: TIMED_WAITING

Thread Thread-1: TIMED_WAITING

Thread Thread-2: TIMED_WAITING

Thread Thread-3: TIMED_WAITING

Thread Thread-4: TIMED_WAITING

Thread Thread-1: Interrupted

Thread Thread-4: Interrupted

Thread Thread-2: Interrupted

Thread Thread-0: Interrupted

Thread Thread-3: Interrupted

ThreadGroup類保存著眾多Thread對象以及關(guān)聯(lián)的ThreadGroup對象?？梢酝ㄟ^調(diào)用該類的方法，訪問線程的信息，還可以對其進(jìn)行各種操作，比如中斷等。

永無止境

ThreadGroup類還有好多方法。請翻閱API文檔，查看完整的方法說明。

拿來主義

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

小有所成

下面是本節(jié)示例所用的代碼的完整版。

Result類的完整代碼：

復(fù)制代碼代碼如下:

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

/**
* 存儲查詢結(jié)果
* Date: 2013-09-30
* Time: 00:45
*/
public class Result {
private String name;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
}

SearchTask類的完整代碼

復(fù)制代碼代碼如下:

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

import java.util.Date;
import java.util.Random;
import java.util.concurrent.TimeUnit;

/**
* 模擬搜索類
* Date: 2013-10-02
* Time: 22:38
*/
public class SearchTask implements Runnable {
private Result result;

    public SearchTask(Result result) {
        this.result = result;
    }

    @Override
    public void run() {
        String name = Thread.currentThread().getName();
        System.out.printf("Thread %s: Start\n", name);
        try {
            doTask();
            result.setName(name);
        } catch (InterruptedException e) {
            System.out.printf("Thread %s: Interrupted\n", name);
            return;
        }
        System.out.printf("Thread %s: End\n", name);
    }

    // 模擬搜索
    private void doTask() throws InterruptedException {
        Random random = new Random(new Date().getTime());
        int value = (int) (random.nextDouble() * 100);
        System.out.printf("Thread %s: %d\n",
                Thread.currentThread().getName(), value);
        TimeUnit.SECONDS.sleep(value);
    }
}

Main類的完整代碼：

復(fù)制代碼代碼如下:

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

import java.util.concurrent.TimeUnit;

/**
* 線程組示例主類
* Date: 2013-10-02
* Time: 22:45
*/
public class Main {
public static void main(String[] args) {
ThreadGroup threadGroup = new ThreadGroup("Searcher");

Result result = new Result();
SearchTask searchTask = new SearchTask(result);

        for (int i = 0; i < 5; i++) {
            Thread thread = new Thread(threadGroup, searchTask);
            thread.start();
            try {
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        System.out.printf("Number of Threads: %d\n", threadGroup.activeCount());
        System.out.println("Information about the Thread Group");
        threadGroup.list();

        Thread[] threads = new Thread[threadGroup.activeCount()];
        threadGroup.enumerate(threads);
        for (int i = 0; i < threadGroup.activeCount(); i++) {
            System.out.printf("Thread %s: %s\n", threads[i].getName(),
                    threads[i].getState());
        }

waitFinish(threadGroup);

threadGroup.interrupt();
}

    // 等待任務(wù)完成
    private static void waitFinish(ThreadGroup threadGroup) {
        while (threadGroup.activeCount() > 9) {
            try {
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

您可能感興趣的文章:

相關(guān)文章

Spring如何在xml文件中配置Bean
這篇文章主要介紹了Spring如何在xml文件中配置Bean的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
2019-07-07
Java 如何實(shí)現(xiàn)時(shí)間控制
這篇文章主要向大家介紹得是Java 如何實(shí)現(xiàn)時(shí)間控制，文章珠岙舉例說明該內(nèi)容，感興趣得小伙伴可以跟小編一起學(xué)習(xí)下面文章內(nèi)容
2021-10-10
SpringMVC框架中使用Filter實(shí)現(xiàn)請求日志打印方式
這篇文章主要介紹了SpringMVC框架中使用Filter實(shí)現(xiàn)請求日志打印方式，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
2021-10-10
關(guān)于java.lang.IncompatibleClassChangeError錯(cuò)誤解決方案
最近開發(fā)中遇到類沖突報(bào)錯(cuò) java.lang.IncompatibleClassChangeError,所以下面這篇文章主要給大家介紹了關(guān)于java.lang.IncompatibleClassChangeError錯(cuò)誤的解決方案,需要的朋友可以參考下
2024-02-02
Spring中的NamespaceHandler接口及相關(guān)軟件包說明
這篇文章主要介紹了Spring中的NamespaceHandler接口及相關(guān)軟件包說明,NamespaceHandler 接口,DefaultBeanDefinitionDocumentReader 使用該接口來處理在spring xml 配置文件中自定義的命名空間,需要的朋友可以參考下
2023-12-12
HelloSpringMVC配置版實(shí)現(xiàn)步驟解析
這篇文章主要介紹了HelloSpringMVC配置版實(shí)現(xiàn)步驟解析,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
2020-09-09
用Java實(shí)現(xiàn)24點(diǎn)游戲
喜歡玩游戲的有福啦,文中有非常詳細(xì)的開發(fā)框架,按著框架來實(shí)現(xiàn)就好啦.而且24點(diǎn)游戲是經(jīng)典的紙牌益智游戲.,需要的朋友可以參考下
2021-05-05
Java數(shù)組的基本操作方法整理
這篇文章主要給大家介紹了關(guān)于Java中數(shù)組的定義和使用的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
2021-06-06
詳解feign調(diào)用session丟失解決方案
這篇文章主要介紹了詳解feign調(diào)用session丟失解決方案，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
2019-02-02
解決idea每次新建項(xiàng)目都需要重新指定maven目錄
這篇文章主要介紹了解決idea每次新建項(xiàng)目都需要配置maven，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
2020-09-09

最新評論

<kbd id="yfutm"><samp id="yfutm"><source id="yfutm"></source></samp></kbd>