阻塞逻辑修改

This commit is contained in:
even 2025-05-29 14:11:37 +08:00
parent 06b1bea076
commit 056f15d68b

View File

@ -183,12 +183,14 @@ public abstract class BaseRunContext {
try {
this.countDownLatch.await();
} catch (InterruptedException e) {
log.error(e.getMessage());
}
log.error(e.getMessage());}
}
private void unpause(){
if (this.countDownLatch!=null) {
this.countDownLatch.countDown();
if (this.countDownLatch.getCount()==0) {
this.countDownLatch=null;
}
}
}
}