在Java中,要使用newCachedThreadPool()
方法创建一个线程池,你需要首先导入java.util.concurrent.Executors
类。newCachedThreadPool()
方法会创建一个线程池,该线程池会根据需要创建新线程,但如果有可用的线程,则会重用它们。当线程池中的线程完成任务后,它们会被放入一个缓存中,以便在将来有新的任务时重新使用。
以下是如何使用newCachedThreadPool()
方法创建线程池的示例:
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Main {
public static void main(String[] args) {
// 创建一个线程池
ExecutorService executorService = Executors.newCachedThreadPool();
// 向线程池提交任务
for (int i = 0; i < 10; i++) {
executorService.submit(() -> {
System.out.println("Task executed by thread: " + Thread.currentThread().getName());
});
}
// 关闭线程池
executorService.shutdown();
}
}
在这个示例中,我们首先导入了java.util.concurrent.Executors
类,然后使用Executors.newCachedThreadPool()
方法创建了一个线程池。接下来,我们向线程池提交了10个任务,每个任务都会打印出执行任务的线程名称。最后,我们调用executorService.shutdown()
方法来关闭线程池。