Java并发工具库（Executors，Future等）实战案例

原创矫情吗；* 2024-11-08 14:06 15阅读 0赞

Java并发工具库提供了多种工具和类来帮助开发者处理并发编程问题。以下是一些常见的并发工具和它们的实战案例：

###1. Executors`Executors` 类是一个工厂类，用于创建预定义配置的线程池。以下是一些常见的线程池类型和它们的使用场景：

- **CachedThreadPool**：创建一个可根据需要创建新线程的线程池，对于短生命周期的异步任务非常有用。
- **FixedThreadPool**：创建一个固定大小的线程池，适用于负载较重的服务器。
- **SingleThreadExecutor**：创建一个单线程的Executor，适用于需要保证任务顺序执行的场景。
- **ScheduledThreadPool**：创建一个用于延迟执行或定期执行任务的线程池。

**实战案例**：
```javaExecutorService executor = Executors.newFixedThreadPool(10); // 创建一个固定大小为10的线程池for (int i =0; i <100; i++) {
 executor.submit(() -> {
//执行任务 System.out.println(Thread.currentThread().getName() + " is running");
 });
}
executor.shutdown(); // 关闭线程池```###2. Future`Future`接口代表异步计算的结果。它提供了检查计算是否完成的方法，以及获取计算结果的方法。

**实战案例**：
```javaExecutorService executor = Executors.newFixedThreadPool(10);
Future<String> future = executor.submit(() -> {
//模拟长时间运行的任务 TimeUnit.SECONDS.sleep(2);
 return "Result of the task";
});

try {
// 获取任务结果，会阻塞直到任务完成String result = future.get();
 System.out.println(result);
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
executor.shutdown();
```###3. Callable 和 FutureTask`Callable`接口与 `Runnable`相似，但它可以返回一个结果，并且可以抛出异常。`FutureTask` 是 `Future`接口的一个实现，用于包装 `Callable`。

**实战案例**：
```javaExecutorService executor = Executors.newFixedThreadPool(10);
FutureTask<Integer> futureTask = new FutureTask<>(new Callable<Integer>() {
@Override public Integer call() throws Exception {
//执行任务并返回结果 return123;
 }
});

executor.submit(futureTask);

try {
// 获取任务结果Integer result = futureTask.get();
 System.out.println("Task result: " + result);
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
executor.shutdown();
```###4. CountDownLatch 和 CyclicBarrier`CountDownLatch` 和 `CyclicBarrier` 是同步辅助类，用于协调多个线程之间的操作。

- **CountDownLatch**：一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。
- **CyclicBarrier**：一个同步辅助类，它允许一组线程互相等待，直到所有线程都到达一个公共屏障点。

**实战案例**（CountDownLatch）：
```javaCountDownLatch latch = new CountDownLatch(3);
ExecutorService executor = Executors.newFixedThreadPool(3);

for (int i =0; i <3; i++) {
 executor.submit(() -> {
 try {
//执行任务 System.out.println("Thread " + Thread.currentThread().getName() + " is running");
} finally {
 latch.countDown(); //计数减1 }
 });
}

try {
 latch.await(); //等待所有任务完成 System.out.println("All tasks are completed");
} catch (InterruptedException e) {
e.printStackTrace();
}
executor.shutdown();
```这些是Java并发工具库中的一些基本工具和实战案例。根据具体的应用场景，你可以选择适合的工具来实现并发控制。