springboot多线程等待

### Spring Boot 中多线程等待机制的实现 在 Spring Boot 应用程序中，可以通过多种方式实现多线程等待机制。以下是几种常见的方法及其具体实现： #### 方法一：使用 `CountDownLatch` 实现线程同步 `CountDownLatch` 是 Java 提供的一个同步工具类，允许一个或多个线程等待其他线程完成操作后再继续执行。 ```java import java.util.concurrent.CountDownLatch; public class CountDownLatchExample { public static void main(String[] args) throws InterruptedException { int threadCount = 3; // 假设有三个子线程需要完成任务 CountDownLatch latch = new CountDownLatch(threadCount); for (int i = 0; i < threadCount; i++) { Thread worker = new Thread(() -> { try { System.out.println(Thread.currentThread().getName() + " is working..."); Thread.sleep(1000); // 模拟耗时任务 } catch (InterruptedException e) { e.printStackTrace(); } finally { latch.countDown(); // 子线程完成后调用 countDown() } }); worker.start(); } latch.await(); // 主线程在此处阻塞，直到所有子线程完成 System.out.println("All threads have finished their work."); } } ``` 这种方法适用于主线程需要等待一组子线程全部完成的情况[^1]。 --- #### 方法二：使用 `CyclicBarrier` 进行屏障控制 `CyclicBarrier` 可以让一组线程到达某个屏障点后才继续向下执行。它适合于需要多个线程协作完成的任务场景。 ```java import java.util.concurrent.BrokenBarrierException; import java.util.concurrent.CyclicBarrier; public class CyclicBarrierExample { private static final int THREAD_COUNT = 3; private static CyclicBarrier barrier = new CyclicBarrier(THREAD_COUNT, () -> { System.out.println("All threads reached the barrier point and can proceed further."); }); public static void main(String[] args) { for (int i = 0; i < THREAD_COUNT; i++) { new Thread(() -> { try { System.out.println(Thread.currentThread().getName() + " is waiting at the barrier."); barrier.await(); // 线程在这里等待，直到所有线程都到达此点 } catch (InterruptedException | BrokenBarrierException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + " has passed the barrier."); }).start(); } } } ``` 这种方式特别适合用于分阶段的工作流，在每一步都需要所有参与方就绪的情况下再进入下一步[^2]。 --- #### 方法三：结合 `CompletableFuture` 的异步编程模型 `CompletableFuture` 是一种更现代的方式，可以用来简化复杂的异步逻辑并提供灵活的结果组合能力。 ```java import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutionException; public class CompletableFutureExample { public static void main(String[] args) throws ExecutionException, InterruptedException { CompletableFuture<Void> future1 = CompletableFuture.runAsync(() -> { simulateWork("Task 1"); }); CompletableFuture<Void> future2 = CompletableFuture.runAsync(() -> { simulateWork("Task 2"); }); CompletableFuture<Void> combinedFuture = CompletableFuture.allOf(future1, future2); combinedFuture.join(); // 阻塞主线程，直到所有任务完成 System.out.println("Both tasks are completed."); } private static void simulateWork(String taskName) { try { System.out.println(taskName + " started by " + Thread.currentThread().getName()); Thread.sleep(1000); // 模拟工作时间 } catch (InterruptedException e) { e.printStackTrace(); } } } ``` 这种模式非常适合处理大量独立但又相互依赖的任务集合。 --- #### 注意事项 当涉及事务管理时，需注意 Spring 默认的事务传播行为不会自动传递到新的线程中。如果需要跨线程共享事务上下文，则可能需要手动配置事务传播策略或者借助第三方库（如 `TransactionTemplate` 或 AOP 切面技术）来解决[^3]。 --- ### 性能优化建议 为了提升系统的并发性能和资源利用率，可以根据实际业务需求调整线程池大小以及任务队列长度设置。例如，通过自定义 `ThreadPoolTaskExecutor` 来精细化控制线程生命周期。 ```java @Bean public TaskExecutor taskExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); executor.setCorePoolSize(5); executor.setMaxPoolSize(10); executor.setQueueCapacity(25); executor.initialize(); return executor; } ``` 上述代码片段展示了如何创建一个可扩展的线程池以适应不同的负载情况。 ---