Commit 5c6e8115 authored by lihao's avatar lihao

提交execute中CountDownLatch await判断

parent 7bd75feb
...@@ -62,8 +62,7 @@ public class TaskExecutor<T, U, R> { ...@@ -62,8 +62,7 @@ public class TaskExecutor<T, U, R> {
} }
})); }));
try { try {
countDownLatch.await(countDownTimeOut, timeUnit); return countDownLatch.await(countDownTimeOut, timeUnit) && failCount.get() <= 0;
return failCount.get() <= 0;
} catch (InterruptedException e) { } catch (InterruptedException e) {
return false; return false;
} finally { } finally {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment