java 常?的线程池模式FixedThreadPool

java 常?的线程池模式FixedThreadPool

线程池中的线程数量是固定的。
当提交一个新任务时，如果线程池中的线程都在运行，新任务就会被放入任务队列中等待执行。
如果线程池中的所有线程都在运行，且任务队列已满，那么线程池会创建新的线程来处理新任务。
使用场景：适用于执行大量计算任务的应用程序，如大数据处理、科学计算等。

import java.util.concurrent.ExecutorService; ?
import java.util.concurrent.Executors; ?
??
public class FixedThreadPoolExample { ?
? ? public static void main(String[] args) { ?
? ? ? ? // 创建一个固定大小的线程池，包含5个线程 ?
? ? ? ? ExecutorService executorService = Executors.newFixedThreadPool(5); ?
??
? ? ? ? // 提交10个任务给线程池执行 ?
? ? ? ? for (int i = 0; i < 10; i++) { ?
? ? ? ? ? ? Runnable worker = new WorkerThread("" + i); ?
? ? ? ? ? ? executorService.execute(worker); ?
? ? ? ? } ?
??
? ? ? ? // 关闭线程池 ?
? ? ? ? executorService.shutdown(); ?
? ? } ?
} ?
??
class WorkerThread implements Runnable { ?
? ? private String command; ?
??
? ? public WorkerThread(String command) { ?
? ? ? ? this.command = command; ?
? ? } ?
??
? ? @Override ?
? ? public void run() { ?
? ? ? ? System.out.println(Thread.currentThread().getName() + "开始处理：" + command); ?
? ? ? ? processCommand(); ?
? ? ? ? System.out.println(Thread.currentThread().getName() + "结束处理：" + command); ?
? ? } ?
??
? ? private void processCommand() { ?
? ? ? ? try { ?
? ? ? ? ? ? Thread.sleep(2000); ?
? ? ? ? } catch (InterruptedException e) { ?
? ? ? ? ? ? e.printStackTrace(); ?
? ? ? ? } ?
? ? } ?
}

在这个例子中，我们创建了一个固定大小为5的线程池，并提交了10个任务给线程池执行。由于线程池的大小是固定的，当线程池中的线程都在运行且任务队列已满时，新任务会被拒绝。因此，这个例子中，只有5个任务会被执行，其他任务会被拒绝。最后，我们关闭了线程池。