|
@@ -117,9 +117,9 @@ public class ConcurrentTask<T> {
|
|
|
} else {
|
|
|
// 巡检周期内(因并发超出限制导致的)警告数量超过100时,减少一个worker,并重置警告数量
|
|
|
workerMessages.offer(warnCount);
|
|
|
- workerController.resetWarnCount();
|
|
|
}
|
|
|
|
|
|
+ workerController.resetWarnCount();
|
|
|
Util.sleep(inspectionPeriod);
|
|
|
}
|
|
|
|