自定义线程池

自定义线程池是一种用于管理和控制并发执行任务的机制。它允许开发者根据应用的需求，配置线程的数量、任务队列、线程存活时间等参数，从而提高应用的性能和稳定性。

基础概念

线程池：线程池是一组预先创建的线程，这些线程可以被重复使用来执行多个任务。线程池通过减少线程创建和销毁的开销，提高了系统的效率。

自定义线程池：自定义线程池允许开发者根据具体需求配置线程池的各种参数，如核心线程数、最大线程数、任务队列、拒绝策略等。

类型

Fixed Thread Pool：固定线程数的线程池。
Cached Thread Pool：可根据需要创建新线程的线程池。
Scheduled Thread Pool：支持定时和周期性任务执行的线程池。
Single Thread Executor：单线程执行器，保证任务顺序执行。

应用场景

Web服务器：处理大量并发请求。
批处理任务：定时或周期性执行的任务。
并发数据处理：如大数据分析、图像处理等。

示例代码（Java）

import java.util.concurrent.*;

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

        for (int i = 0; i < 10; i++) {
            Runnable worker = new WorkerThread("" + i);
            executor.execute(worker);
        }
        executor.shutdown();
        while (!executor.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;
    }
}