Skip to content

Commit 5a79c99

Browse files
authored
Merge pull request #18 from codingapi/dev
fix remove bug
2 parents 7739417 + 498a31f commit 5a79c99

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

springboot-starter/src/main/java/com/codingapi/springboot/framework/trigger/TriggerContext.java

+8-3
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,13 @@
11
package com.codingapi.springboot.framework.trigger;
22

3+
import lombok.extern.slf4j.Slf4j;
4+
35
import java.lang.reflect.ParameterizedType;
6+
import java.util.ArrayList;
47
import java.util.Iterator;
58
import java.util.List;
69
import java.util.Map;
710
import java.util.concurrent.ConcurrentHashMap;
8-
import java.util.concurrent.CopyOnWriteArrayList;
911

1012

1113
/**
@@ -15,6 +17,7 @@
1517
* Trigger是单独的消息数据不占用Event的通道。由于Event利用了Spring的事件底层,因此在大规模的事件情况下会堵塞spring的事件通道。
1618
*/
1719
@SuppressWarnings("all")
20+
@Slf4j
1821
public class TriggerContext{
1922

2023
public static TriggerContext getInstance() {
@@ -38,7 +41,7 @@ public void addTrigger(TriggerHandler handler){
3841
Class<? extends Trigger> clazz = getTriggerClass(handler);
3942
List<TriggerHandler> triggerList = this.triggers.get(clazz);
4043
if(triggerList==null){
41-
triggerList = new CopyOnWriteArrayList<>();
44+
triggerList = new ArrayList<>();
4245
this.triggers.put(clazz,triggerList);
4346
}
4447
triggerList.add(handler);
@@ -74,7 +77,9 @@ public void trigger(Trigger trigger){
7477
iterator.remove();
7578
}
7679
}
77-
}catch (Exception e){}
80+
}catch (Exception e){
81+
log.warn("trigger error:{}",e.getLocalizedMessage());
82+
}
7883
}
7984
}
8085
}

0 commit comments

Comments
 (0)