diff --git a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/slotOffer/SlotOfferELSpringbootTest.java b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/slotOffer/SlotOfferELSpringbootTest.java index f25822b46..75ad2644d 100644 --- a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/slotOffer/SlotOfferELSpringbootTest.java +++ b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/slotOffer/SlotOfferELSpringbootTest.java @@ -42,26 +42,23 @@ public class SlotOfferELSpringbootTest extends BaseTest { Set set = new ConcurrentHashSet<>(); Set> futureSet = new ConcurrentHashSet<>(); Set error = new ConcurrentHashSet<>(); - for (int i = 0; i < 200; i++) { + for (int i = 0; i < 60000; i++) { futureSet.add(CompletableFuture.supplyAsync(() -> { - for (int j = 0; j < 300; j++) { - int index=0; - try{ - index = DataBus.offerSlotByClass(ListUtil.toList(DefaultContext.class)); - boolean flag = set.add(index); - if (!flag){ - error.add(Integer.toString(index)); - } - }catch (Exception e) { - error.add(e.getMessage()); - }finally { - DataBus.releaseSlot(index); - boolean flag = set.remove(index); - if(!flag){ - error.add(Integer.toString(index)); - } + int index=0; + try{ + index = DataBus.offerSlotByClass(ListUtil.toList(DefaultContext.class)); + boolean flag = set.add(index); + if (!flag){ + error.add(Integer.toString(index)); + } + }catch (Exception e) { + error.add(e.getMessage()); + }finally { + DataBus.releaseSlot(index); + boolean flag = set.remove(index); + if(!flag){ + error.add(Integer.toString(index)); } - } return Boolean.TRUE; }));