Java创建线程池的代码怎么写

Java中创建线程池的代码可以按照以下步骤进行：

1. 导入相关的类和包：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

2. 创建一个线程池对象：

ExecutorService executor = Executors.newFixedThreadPool(5);

这里使用Executors.newFixedThreadPool()方法创建一个固定大小的线程池，参数5表示线程池中的线程数量为5。

3. 定义一个实现Runnable接口的任务类：

class MyTask implements Runnable {
    public void run() {
        // 执行任务逻辑
    }
}

4. 提交任务给线程池：

executor.submit(new MyTask());

这里使用submit()方法将任务提交给线程池进行执行。

5. 关闭线程池：

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();
    }
}