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

49次阅读

共计 803 个字符，预计需要花费 3 分钟才能阅读完成。

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