91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

java newfixedthreadpool任務怎樣提交

小樊
81
2024-11-26 15:00:23
欄目: 編程語言

在Java中,要使用newFixedThreadPool提交任務,首先需要導入java.util.concurrent包中的ExecutorServiceExecutors類。然后,可以使用Executors類創建一個固定大小的線程池,接著使用ExecutorServicesubmit方法提交任務。

下面是一個簡單的示例:

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class FixedThreadPoolExample {
    public static void main(String[] args) {
        // 創建一個固定大小為3的線程池
        ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);

        // 提交任務到線程池
        for (int i = 0; i < 10; i++) {
            final int taskNumber = i;
            fixedThreadPool.submit(() -> {
                System.out.println("Task " + taskNumber + " is running on thread " + Thread.currentThread().getName());
                try {
                    // 模擬任務執行時間
                    TimeUnit.SECONDS.sleep(2);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + taskNumber + " is completed");
            });
        }

        // 關閉線程池
        fixedThreadPool.shutdown();
        try {
            // 等待所有任務完成
            if (!fixedThreadPool.awaitTermination(30, TimeUnit.SECONDS)) {
                fixedThreadPool.shutdownNow();
            }
        } catch (InterruptedException e) {
            fixedThreadPool.shutdownNow();
        }
    }
}

在這個示例中,我們創建了一個固定大小為3的線程池,并提交了10個任務。每個任務都會打印出它正在運行的線程名稱,然后休眠2秒,最后打印出任務完成的信息。在所有任務提交完成后,我們關閉了線程池。

0
福建省| 泰和县| 丹巴县| 大理市| 安平县| 灵丘县| 湘潭市| 南靖县| 乌鲁木齐县| 石棉县| 荆门市| 巍山| 自治县| 永川市| 赣州市| 水富县| 阜宁县| 囊谦县| 沈阳市| 金堂县| 承德市| 宝应县| 珲春市| 柘城县| 潮州市| 上林县| 望江县| 赣榆县| 五台县| 盐津县| 义马市| 通河县| 两当县| 黄冈市| 邢台县| 合水县| 揭西县| 库车县| 南汇区| 玛多县| 余姚市|