给我一个java使用线程池完成多线程的代码示例
时间: 2023-05-12 20:06:10 浏览: 127
当然可以,以下是一个简单的 Java 线程池示例:
```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolExample {
public static void main(String[] args) {
// 创建一个线程池,其中包含 5 个线程
ExecutorService executor = Executors.newFixedThreadPool(5);
// 创建 10 个任务并提交给线程池
for (int i = 0; i < 10; i++) {
Runnable worker = new WorkerThread("" + i);
executor.execute(worker);
}
// 关闭线程池
executor.shutdown();
while (!executor.isTerminated()) {
}
System.out.println("所有任务已完成");
}
}
class WorkerThread implements Runnable {
private String message;
public WorkerThread(String s) {
this.message = s;
}
public void run() {
System.out.println(Thread.currentThread().getName() + " 开始执行任务: " + message);
processMessage();
System.out.println(Thread.currentThread().getName() + " 完成任务: " + message);
}
private void processMessage() {
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
```
这个示例创建了一个包含 5 个线程的线程池,并提交了 10 个任务。每个任务都是一个 `WorkerThread` 对象,它实现了 `Runnable` 接口。在 `run()` 方法中,我们可以编写我们的任务逻辑。在这个示例中,我们只是简单地让线程休眠 2 秒钟,然后输出一些信息。最后,我们关闭了线程池,并等待所有任务完成。
阅读全文