Java中如何创建线程池

在Java中，创建线程池通常使用java.util.concurrent.Executors类提供的工厂方法。以下是一些常用的线程池创建方式：

1. Fixed Thread Pool（固定大小线程池）： 创建一个固定大小的线程池，当有新任务提交时，如果线程池中有空闲线程，则立即执行。如果没有，则新任务会被暂存到一个任务队列中，等待有线程空闲时再执行。

   import java.util.concurrent.ExecutorService;
   import java.util.concurrent.Executors;
   
   ExecutorService fixedThreadPool = Executors.newFixedThreadPool(int nThreads);
   

   AI代码助手复制代码

2. Cached Thread Pool（可缓存线程池）： 创建一个可缓存的线程池，如果线程池的大小超过了处理需要，可灵活回收空闲线程（空闲线程超过60秒），若无可回收，则新建线程。

   ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
   

   AI代码助手复制代码

3. Single Thread Executor（单线程执行器）： 创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序(FIFO)执行。

   ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
   

   AI代码助手复制代码

4. Scheduled Thread Pool（定时线程池）： 创建一个定长线程池，支持定时及周期性任务执行。

   import java.util.concurrent.ScheduledExecutorService;
   import java.util.concurrent.Executors;
   
   ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(int corePoolSize);
   

   AI代码助手复制代码

5. Work Stealing Pool（工作窃取线程池）： 创建一个拥有固定数量线程的线程池，其内部使用了一种称为“工作窃取”的算法来平衡任务分配。这种线程池适用于大量计算密集型任务。

   import java.util.concurrent.ForkJoinPool;
   
   ForkJoinPool workStealingPool = new ForkJoinPool();
   

   AI代码助手复制代码

创建了线程池之后，你可以使用execute(Runnable)方法提交任务，或者使用submit(Callable<T>)方法提交带有返回值的任务。最后，不要忘记在不再需要线程池时调用shutdown()或shutdownNow()方法来关闭线程池。

// 提交任务
fixedThreadPool.execute(new RunnableTask());

// 关闭线程池
fixedThreadPool.shutdown();

使用线程池时，需要注意合理配置线程池的大小，以及正确处理任务的提交和异常情况，以避免资源泄露和性能问题。

亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>