java 线程池怎么使用
时间: 2024-02-29 10:49:17 浏览: 72
java多线程系列(六)线程池原理及其使用.docx
Java线程池的使用可以通过以下步骤来实现:
1. 创建线程池对象:
```java
ExecutorService executor = Executors.newFixedThreadPool(5);
```
这里使用了`Executors.newFixedThreadPool()`方法创建了一个固定大小为5的线程池。
2. 创建任务对象:
```java
Runnable task = new TestRunnable();
```
这里的`TestRunnable`是一个实现了`Runnable`接口的自定义任务类。
3. 提交任务给线程池执行:
```java
executor.execute(task);
```
使用`execute()`方法将任务提交给线程池执行。
4. 关闭线程池:
```java
executor.shutdown();
```
在任务执行完毕后,需要调用`shutdown()`方法关闭线程池。
下面是一个完整的示例代码:
```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolExample {
public static void main(String[] args) {
// 创建线程池对象
ExecutorService executor = Executors.newFixedThreadPool(5);
// 创建任务对象
Runnable task = new TestRunnable();
// 提交任务给线程池执行
executor.execute(task);
// 关闭线程池
executor.shutdown();
}
}
class TestRunnable implements Runnable {
public void run() {
System.out.println(Thread.currentThread().getName() + "线程被调用了。");
while (true) {
try {
Thread.sleep(5000);
System.out.println(Thread.currentThread().getName());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
```
阅读全文