|
|
@@ -48,6 +48,21 @@ public class ConcurrentTask<T> {
|
|
|
*/
|
|
|
private int inspectionPeriod = 60;
|
|
|
|
|
|
+ /**
|
|
|
+ * 任务名称
|
|
|
+ */
|
|
|
+ private String taskName;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 构造函数
|
|
|
+ *
|
|
|
+ * @param taskName
|
|
|
+ */
|
|
|
+ public ConcurrentTask(String taskName) {
|
|
|
+ super();
|
|
|
+ this.taskName = taskName;
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* 添加处理元素
|
|
|
*
|
|
|
@@ -87,6 +102,8 @@ public class ConcurrentTask<T> {
|
|
|
int size = queue.size();
|
|
|
int activeCount = threadPoolExecutor.getActiveCount();
|
|
|
|
|
|
+ LOG.info("taskName [" + taskName + "]. activeCount = " + activeCount);
|
|
|
+
|
|
|
int warnCount = workerController.getWarnCount();
|
|
|
// 巡检周期内(因并发超出限制导致的)警告数量未超过100时,增加一个worker
|
|
|
if (warnCount <= 100) {
|
WANG