Java中创建线程池的代码可以按照以下步骤进行:
导入相关的类和包:import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;创建一个线程池对象:ExecutorService executor = Executors.newFixedThreadPool(5);这里使用Executors.newFixedThreadPool()方法创建一个固定大小的线程池,参数5表示线程池中的线程数量为5。
class MyTask implements Runnable { public void run() { // 执行任务逻辑 }}提交任务给线程池:executor.submit(new MyTask());这里使用submit()方法将任务提交给线程池进行执行。
executor.shutdown();在任务执行完毕后,需要调用shutdown()方法关闭线程池。
完整的示例代码如下所示:
import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;class MyTask implements Runnable { public void run() { // 执行任务逻辑 }}public class ThreadPoolExample { public static void main(String[] args) { ExecutorService executor = Executors.newFixedThreadPool(5); for (int i = 0; i < 10; i++) { executor.submit(new MyTask()); } executor.shutdown(); }} 
