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

溫馨提示×

java怎么自定義并發線程池

小億
91
2023-10-24 21:34:52
欄目: 編程語言

要自定義并發線程池,可以使用ThreadPoolExecutor類來實現。ThreadPoolExecutorExecutorService接口的一個實現類,可以用來創建和管理線程池。

以下是一個自定義并發線程池的示例:

import java.util.concurrent.*;

public class CustomThreadPool {
    public static void main(String[] args) {
        // 核心線程數
        int corePoolSize = 2;
        // 最大線程數
        int maximumPoolSize = 5;
        // 空閑線程存活時間
        long keepAliveTime = 10;
        // 時間單位
        TimeUnit unit = TimeUnit.SECONDS;
        // 工作隊列
        BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(10);

        // 創建自定義線程池
        ThreadPoolExecutor threadPool = new ThreadPoolExecutor(
                corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);

        // 提交任務給線程池
        for (int i = 0; i < 20; i++) {
            threadPool.execute(new Task(i));
        }

        // 關閉線程池
        threadPool.shutdown();
    }

    static class Task implements Runnable {
        private int taskId;

        public Task(int taskId) {
            this.taskId = taskId;
        }

        @Override
        public void run() {
            System.out.println("Task " + taskId + " is running.");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

在上面的示例中,我們創建了一個ThreadPoolExecutor線程池,設置了核心線程數為2,最大線程數為5,空閑線程存活時間為10秒。然后,我們使用execute()方法提交了20個任務給線程池。每個任務是一個Task對象,實現了Runnable接口。在run()方法中,我們打印了任務的id,并讓線程睡眠1秒。

最后,我們調用了shutdown()方法來關閉線程池。

0
海阳市| 赣州市| 济宁市| 泗阳县| 虎林市| 广宗县| 澜沧| 罗山县| 阿拉善右旗| 鸡泽县| 玉门市| 金湖县| 皮山县| 晋州市| 阳谷县| 龙里县| 黔西| 蚌埠市| 湘潭县| 斗六市| 木里| 清苑县| 泽库县| 贞丰县| 南澳县| 方正县| 民和| 万全县| 天气| 汉阴县| 日喀则市| 鄢陵县| 文安县| 汉源县| 林州市| 青铜峡市| 泸州市| 车致| 象山县| 遵义县| 长宁县|