public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-14 20:22:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

修改测试用例

Browse Source
This commit is contained in:
everywhere.z
2022-12-22 15:37:11 +08:00
parent 769eb846fd
commit 5b35ad904a
1 changed files with 15 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/slotOffer/SlotOfferELSpringbootTest.java
View File

@@ -42,26 +42,23 @@ public class SlotOfferELSpringbootTest extends BaseTest {
Set<Integer> set = new ConcurrentHashSet<>();
Set<CompletableFuture<Boolean>> futureSet = new ConcurrentHashSet<>();
Set<String> 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;
}));