等待线程池BUG修复

v1.4.1
Parker 4 years ago
parent dc389f8051
commit ea88fd330a

@ -38,12 +38,12 @@ public class AsyncProcessQueueWait {
if (gift != null) { if (gift != null) {
try { try {
gift.run(); gift.run();
// 标示已执行
count.decrementAndGet();
} catch (Exception e) { } catch (Exception e) {
String errMsg = StrUtil.format("线程池-包装的目标执行异常: {}", e.getMessage()); String errMsg = StrUtil.format("线程池-包装的目标执行异常: {}", e.getMessage());
log.error(errMsg, e); log.error(errMsg, e);
} finally { } finally {
// 标示已执行
count.decrementAndGet();
latch.countDown(); latch.countDown();
} }
} }

Loading…
Cancel
Save