Javaでマルチスレッド環境で使用する独自の、並行処理スレッドプールを作成する方法は?

2年 ago
蓮, 翼
1 minute

スレッドプールのカスタマイズには、ThreadPoolExecutor クラスを活用できます。ThreadPoolExecutor クラスは、スレッドプールの作成と管理を可能にする、ExecutorService インターフェイスの実装クラスです。

以下はのカスタムの同時実行スレッドプールの例です。

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() メソッドを呼び出しました。

bannerAds