Java ExecutorService的线程池大小如何设置

在Java中，ExecutorService是一个接口，它提供了一种将任务提交给执行的机制。要设置线程池的大小，您需要创建一个实现了ExecutorService接口的类的实例，例如ThreadPoolExecutor。线程池的大小可以通过构造函数或setter方法来设置。

以下是如何创建一个具有固定大小的线程池的示例：

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

public class ThreadPoolExample {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池，大小为5
        ExecutorService executorService = Executors.newFixedThreadPool(5);

        // 提交任务给线程池
        for (int i = 0; i < 10; i++) {
            Runnable worker = new WorkerThread("" + i);
            executorService.execute(worker);
        }

        // 关闭线程池
        executorService.shutdown();
        while (!executorService.isTerminated()) {
        }
        System.out.println("Finished all threads");
    }
}

class WorkerThread implements Runnable {
    private String command;

    public WorkerThread(String s) {
        this.command = s;
    }

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + " Start. Command = " + command);
        processCommand();
        System.out.println(Thread.currentThread().getName() + " End.");
    }

    private void processCommand() {
        try {
            Thread.sleep(500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    @Override
    public String toString() {
        return this.command;
    }
}

在这个例子中，我们创建了一个固定大小为5的线程池。这意味着线程池最多可以同时运行5个任务。当所有任务都提交给线程池后，线程池会等待所有任务完成，然后关闭。

您还可以使用ThreadPoolExecutor类来自定义线程池的行为，例如设置线程池的最大大小、队列容量等。以下是一个示例：

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

public class CustomThreadPoolExample {
    public static void main(String[] args) {
        // 创建一个自定义的线程池
        ThreadPoolExecutor executorService = new ThreadPoolExecutor(
                5, // 核心线程数
                10, // 最大线程数
                60L, // 空闲线程存活时间
                TimeUnit.SECONDS, // 时间单位
                new ArrayBlockingQueue<>(20) // 任务队列
        );

        // 提交任务给线程池
        for (int i = 0; i < 30; i++) {
            Runnable worker = new WorkerThread("" + i);
            executorService.execute(worker);
        }

        // 关闭线程池
        executorService.shutdown();
        while (!executorService.isTerminated()) {
        }
        System.out.println("Finished all threads");
    }
}

在这个例子中，我们创建了一个自定义的线程池，核心线程数为5，最大线程数为10，空闲线程存活时间为60秒，任务队列容量为20。这意味着线程池最多可以同时运行10个任务，当任务队列满了之后，线程池会创建新的线程，直到达到最大线程数。