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