Java Spring如何实现多线程操作并等待完成

在Java Spring框架中，实现多线程操作并等待所有线程完成可以通过多种方式来实现。以下是一个基本的示例，展示了如何使用ExecutorService和CountDownLatch来实现这一需求。

基础概念

ExecutorService: 是Java提供的用于管理和控制线程的高级接口，它简化了线程的创建和管理。
CountDownLatch: 是一个同步辅助类，允许一个或多个线程等待，直到在其他线程中执行的一组操作完成。

实现步骤

创建一个线程池：使用Executors工具类来创建一个固定大小的线程池。
提交任务：将需要执行的任务提交到线程池中。
等待所有任务完成：使用CountDownLatch来确保主线程等待所有子线程完成任务。

示例代码

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class MultiThreadExample {

    public static void main(String[] args) throws InterruptedException {
        int numberOfTasks = 5; // 假设有5个任务需要并行执行
        ExecutorService executorService = Executors.newFixedThreadPool(numberOfTasks);
        CountDownLatch latch = new CountDownLatch(numberOfTasks);

        for (int i = 0; i < numberOfTasks; i++) {
            executorService.submit(() -> {
                try {
                    // 模拟任务执行
                    System.out.println("Task started by thread: " + Thread.currentThread().getName());
                    Thread.sleep((long) (Math.random() * 1000));
                    System.out.println("Task completed by thread: " + Thread.currentThread().getName());
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                } finally {
                    latch.countDown(); // 任务完成，计数器减一
                }
            });
        }

        latch.await(); // 主线程等待所有任务完成
        executorService.shutdown(); // 关闭线程池
        System.out.println("All tasks have been completed.");
    }
}