newCachedThreadPool
是 Java 中 java.util.concurrent.Executors
类的一个方法,它创建了一个可缓存的线程池。这个线程池在需要时会创建新的线程,但如果线程池的大小超过了处理需要,可缓存的线程会被复用。当任务完成后,线程不会立即销毁,而是返回到线程池中,等待下一个任务。这种线程池适用于任务数量不确定的场景。
以下是使用 newCachedThreadPool
的示例:
import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class CachedThreadPoolExample { public static void main(String[] args) { // 创建一个可缓存的线程池 ExecutorService cachedThreadPool = Executors.newCachedThreadPool(); // 提交任务到线程池 for (int i = 0; i < 10; i++) { final int taskNumber = i; cachedThreadPool.submit(() -> { System.out.println("Task " + taskNumber + " is executed by thread " + Thread.currentThread().getName()); try { // 模拟任务执行耗时 Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } }); } // 关闭线程池 cachedThreadPool.shutdown(); } }
在这个示例中,我们创建了一个可缓存的线程池 cachedThreadPool
,然后提交了 10 个任务到线程池。每个任务打印出它的编号和执行它的线程名称。任务执行完成后,线程不会立即销毁,而是返回到线程池中,等待下一个任务。最后,我们调用 shutdown()
方法关闭线程池。