亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

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
尉犁县| 师宗县| 沽源县| 陆丰市| 渝中区| 扶绥县| 邢台县| 开平市| 怀安县| 昆山市| 屏东市| 新泰市| 犍为县| 根河市| 永丰县| 略阳县| 屯门区| 凉城县| 南陵县| 阳东县| 赣州市| 汝州市| 缙云县| 滁州市| 虎林市| 凌海市| 杨浦区| 石柱| 共和县| 阿拉善左旗| 称多县| 徐闻县| 瑞昌市| 平遥县| 萨嘎县| 桃源县| 敦化市| 贵定县| 深州市| 黄冈市| 永胜县|