Java中的并发工具类（如ExecutorService）使用案例

原创悠悠 2024-10-12 10:12 50阅读 0赞

在Java中，`ExecutorService`是一个用于管理线程池的接口。它提供了一种异步执行任务的方式，有助于提高程序性能和资源利用率。

以下是一些使用`ExecutorService`的实际案例：

1. **定时任务**：
   你可以创建一个`FixedThreadPool`，为每个需要定期执行的任务分配一个线程。

```java
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class TimedTaskExample {
    public static void main(String[] args) {
        // 创建固定大小的线程池
        ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交任务到线程池执行
        for (int i = 0; i < 10; i++) {
            final int index = i;
            executor.submit(() -> {
                System.out.println("Task " + index + " executed at " + new Date());
            });
        }

// 关闭线程池，防止资源泄露
        executor.shutdown();
        try {
            // 等待所有任务完成或者线程池被中断（如系统崩溃）
            executor.awaitTermination(10, TimeUnit.SECONDS);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

2. **并发计算**：
   在需要同时处理大量数据的场景中，可以使用`ExecutorService`进行并行计算。

```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class ConcurrentComputingExample {
    public static void main(String[] args) {
        // 创建固定大小的线程池
        ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交任务到线程池执行
        for (int i = 0; i < 10; i++) {
            final int index = i;
            executor.submit(() -> {
                double result = calculateDouble(index);
                System.out.println("Task " + index + " calculated result: " + result);
            });
        }

private static double calculateDouble(int index) {
        // 这里是你的计算逻辑，例如加、减、乘、除等
        return Math.pow(2, index)); // 一个简单的示例，假设计算的是指数函数
    }
}
```

以上就是`ExecutorService`在Java中的一些使用案例。