2929import java .util .concurrent .ConcurrentLinkedQueue ;
3030import java .util .concurrent .TimeUnit ;
3131import java .util .concurrent .atomic .AtomicBoolean ;
32- import java .util .concurrent .atomic .AtomicInteger ;
3332import java .util .function .BiConsumer ;
3433import java .util .function .Consumer ;
3534
@@ -41,7 +40,6 @@ public class EventManagement {
4140 private final ConcurrentHashMap <String , Method > EVENT_HANDLER_MAP = new ConcurrentHashMap <>();
4241 private final ConcurrentHashMap <String , ConcurrentLinkedQueue <Method >> EVENT_LISTENER_MAP = new ConcurrentHashMap <>();
4342 private final ConcurrentHashMap <String , BiConsumer <Class <?>, Object >> PLUGIN_EVENT_HANDLER_MAP = new ConcurrentHashMap <>();
44- private final AtomicInteger failureEventNum = new AtomicInteger (0 );
4543 private HashSet <String > classesList = new HashSet <>();
4644 private static final int ASYNC_THREAD_NUM = Runtime .getRuntime ().availableProcessors ();
4745
@@ -117,7 +115,7 @@ private void handleRestart(RestartEvent event) {
117115 }
118116
119117 /**
120- * 根绝buildEventRequest中的信息创建任务
118+ * 根据buildEventRequest中的信息创建任务
121119 *
122120 * @param buildEventRequestEvent build event request
123121 * @return true如果构建失败,false构建成功
@@ -533,7 +531,6 @@ private void eventHandle(ConcurrentLinkedQueue<Event> eventQueue) {
533531 if (event .allRetryFailed ()) {
534532 //判断是否超过最大次数
535533 event .setFailed ();
536- failureEventNum .incrementAndGet ();
537534 if (isDebug ) {
538535 System .err .println ("任务超时---" + event );
539536 }
0 commit comments