java中怎么创建线程池?
时间: 2023-09-27 22:08:58 浏览: 102
Java中可以通过以下步骤创建线程池:
1. 导入java.util.concurrent.Executors和java.util.concurrent.ExecutorService类。
2. 调用Executors类的静态方法创建线程池。例如,可以使用以下代码创建一个固定大小的线程池:
```java
ExecutorService executor = Executors.newFixedThreadPool(nThreads);
```
其中nThreads是线程池的大小。
3. 通过调用ExecutorService类的submit()方法提交任务给线程池执行。例如,可以使用以下代码提交一个任务:
```java
executor.submit(new Runnable() {
@Override
public void run() {
// 任务代码
}
});
```
4. 关闭线程池。一般情况下,线程池需要在程序结束前关闭。可以使用以下代码关闭线程池:
```java
executor.shutdown();
```
完整的示例代码如下:
```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class MyThreadPool {
public static void main(String[] args) {
// 创建固定大小的线程池
ExecutorService executor = Executors.newFixedThreadPool(5);
// 提交任务给线程池执行
for (int i = 0; i < 10; i++) {
executor.submit(new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + " is running.");
}
});
}
// 关闭线程池
executor.shutdown();
}
}
```
阅读全文