Java并发工具类：ThreadPoolExecutor应用实例

原创 ╰半橙微兮° 2024-10-23 17:03 61阅读 0赞

`ThreadPoolExecutor`是Java中的一个并行执行线程的工具类。当你的应用程序中有大量的、但不需要立即执行的任务时，`ThreadPoolExecutor`就显得非常有用。

下面是一个简单的`ThreadPoolExecutor`应用实例，我们将创建一个线程池来处理任务：

```java
import java.util.concurrent.*;

public class ThreadPoolExecutorExample {

public static void main(String[] args) {

// 创建一个线程池，最大线程数为5
        ExecutorService executor = Executors.newFixedThreadPool(5);

// 定义要执行的任务列表
        List<Runnable> tasks = new ArrayList<>();
        for (int i = 0; i < 10; i++) { // 创建10个任务 tasks.add(new Task("Task " + i))); }

// 并行提交任务到线程池
        executor.invokeAll(tasks);

// 关闭线程池，释放资源
        executor.shutdown();
        while (!executor.isTerminated())) {
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

System.out.println("Task execution completed.");

}

// 任务示例类
    static class Task implements Runnable {

private String taskName;

public Task(String taskName) {
            this.taskName = taskName;
        }

@Override
        public void run() {
            System.out.println(taskName + " started..."));
            try {
                Thread.sleep(2000); // 模拟耗时操作
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(taskName + " completed..."));
        }

}

}
```

这个例子中，我们创建了一个固定大小的线程池（5个线程），然后定义了10个任务，并将它们并行提交给线程池执行。最后，我们关闭线程池释放资源。