mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-10-14 20:17:51 +00:00
ref[event]: ArrayList replaces LinkedList in event collection
This commit is contained in:
1 parent
67fd9ad1d2
commit
a4e28e1014
1 file changed
+3
-3
@@ -26,8 +26,8 @@ import io.netty.util.concurrent.FastThreadLocalThread;
|
|||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
||||||
|
import java.util.ArrayList;
|
||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
||||||
import java.util.LinkedList;
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.concurrent.Executor;
|
import java.util.concurrent.Executor;
|
||||||
@@ -148,9 +148,9 @@ public abstract class EventBus {
|
|||||||
*/
|
*/
|
||||||
public static void registerEventReceiver(Class<? extends IEvent> eventType, IEventReceiver receiver, boolean asyncFlag) {
|
public static void registerEventReceiver(Class<? extends IEvent> eventType, IEventReceiver receiver, boolean asyncFlag) {
|
||||||
if (asyncFlag) {
|
if (asyncFlag) {
|
||||||
receiverMapAsync.computeIfAbsent(eventType, it -> new LinkedList<>()).add(receiver);
|
receiverMapAsync.computeIfAbsent(eventType, it -> new ArrayList<>(1)).add(receiver);
|
||||||
} else {
|
} else {
|
||||||
receiverMapSync.computeIfAbsent(eventType, it -> new LinkedList<>()).add(receiver);
|
receiverMapSync.computeIfAbsent(eventType, it -> new ArrayList<>(1)).add(receiver);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in new issue
Block a user