Java スレッドプール Executor 設定方法【基本と実践】

1年 ago
優斗, 朝陽
1 minute

Javaでは、ThreadPoolExecutorのコンストラクタを設定することで、スレッドプールを作成し、スレッドプールの動作を制御するためのいくつかのパラメータを設定することができます。以下はThreadPoolExecutorを構成する方法を示すサンプルコードです。

import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class Main {
    public static void main(String[] args) {
        // 创建一个线程池，其中包含5个线程
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
            5, // 核心线程数
            10, // 最大线程数
            60, // 空闲线程存活时间
            TimeUnit.SECONDS, // 时间单位
            new LinkedBlockingQueue<Runnable>() // 阻塞队列
        );
        
        // 设置拒绝策略为直接抛出异常
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
        
        // 执行任务
        executor.execute(new MyTask());
        
        // 关闭线程池
        executor.shutdown();
    }
}

class MyTask implements Runnable {
    @Override
    public void run() {
        System.out.println("Hello from MyTask!");
    }
}

上記のサンプルコードでは、ThreadPoolExecutorオブジェクトを作成し、コアスレッド数を5、最大スレッド数を10、アイドルスレッドの生存時間を60秒、ブロッキングキューをLinkedBlockingQueueに設定しました。その後、リジェクトポリシーを直接例外を投げるように設定し、最後に1つのタスクを実行してスレッドプールをシャットダウンしました。ThreadPoolExecutorのパラメータを自分のニーズに合わせて構成することで、さまざまなシーンに対応できます。

bannerAds