阅读量:0
Java中创建线程池的代码可以按照以下步骤进行:
- 导入相关的类和包:
import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors;
- 创建一个线程池对象:
ExecutorService executor = Executors.newFixedThreadPool(5);
这里使用Executors.newFixedThreadPool()
方法创建一个固定大小的线程池,参数5表示线程池中的线程数量为5。
- 定义一个实现Runnable接口的任务类:
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(); } }