From 14445ccc77ccddc444ce7a06accb3d1fe5aef4da Mon Sep 17 00:00:00 2001 From: Looly Date: Thu, 2 Jan 2025 13:33:08 +0800 Subject: [PATCH] add test --- .../hutool/extra/aop/IssueIBF20ZTest.java | 47 +++++++++++++++++++ 1 file changed, 47 insertions(+) create mode 100644 hutool-extra/src/test/java/org/dromara/hutool/extra/aop/IssueIBF20ZTest.java diff --git a/hutool-extra/src/test/java/org/dromara/hutool/extra/aop/IssueIBF20ZTest.java b/hutool-extra/src/test/java/org/dromara/hutool/extra/aop/IssueIBF20ZTest.java new file mode 100644 index 000000000..65dc78f62 --- /dev/null +++ b/hutool-extra/src/test/java/org/dromara/hutool/extra/aop/IssueIBF20ZTest.java @@ -0,0 +1,47 @@ +package org.dromara.hutool.extra.aop; + +import org.dromara.hutool.core.thread.ThreadUtil; +import org.dromara.hutool.extra.aop.engine.ProxyEngine; +import org.dromara.hutool.extra.aop.engine.ProxyEngineFactory; +import org.junit.jupiter.api.Test; + +import java.util.concurrent.CountDownLatch; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.atomic.AtomicInteger; + +import static org.junit.jupiter.api.Assertions.assertEquals; + +public class IssueIBF20ZTest { + @Test + public void testLoadFirstAvailableConcurrent() throws InterruptedException { + // 创建一个固定大小的线程池 + final int threadCount = 1000; + final ExecutorService executorService = ThreadUtil.newExecutor(threadCount); + + // 创建一个 CountDownLatch，用于等待所有任务完成 + final CountDownLatch latch = new CountDownLatch(threadCount); + + // 计数器用于统计成功加载服务提供者的次数 + final AtomicInteger successCount = new AtomicInteger(0); + + // 提交多个任务到线程池 + for (int i = 0; i < threadCount; i++) { + executorService.submit(() -> { + final ProxyEngine factory = ProxyEngineFactory.createEngine(); + if (factory != null) { + successCount.incrementAndGet(); + } + latch.countDown(); // 每个任务完成时，计数减一 + }); + } + + // 等待所有任务完成 + latch.await(); + + // 关闭线程池并等待所有任务完成 + executorService.shutdown(); + + // 验证所有线程都成功加载了服务提供者 + assertEquals(threadCount, successCount.get()); + } +}