j62
/
ctbrec
2
3
Fork 2
Code Issues 9 Pull Requests Packages Projects Releases 3 Wiki Activity

Code cleanup

This commit is contained in:
0xboobface 2020-01-04 16:13:03 +01:00
parent 242897719b
commit 9037b525bd
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
common/src/main/java/ctbrec/event/EventBusHolder.java
View File

@ -2,6 +2,7 @@ package ctbrec.event;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
import java.util.UUID;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import org.slf4j.Logger; import org.slf4j.Logger;
@ -11,10 +12,18 @@ import com.google.common.eventbus.AsyncEventBus;
import com.google.common.eventbus.EventBus; import com.google.common.eventbus.EventBus;
public class EventBusHolder { public class EventBusHolder {
private static final transient Logger LOG = LoggerFactory.getLogger(EventBusHolder.class); private static final Logger LOG = LoggerFactory.getLogger(EventBusHolder.class);
private static Map<String, EventHandler> handlers = new HashMap<>(); private static Map<String, EventHandler> handlers = new HashMap<>();
public static final EventBus BUS = new AsyncEventBus(Executors.newFixedThreadPool(10)); private EventBusHolder() {}
public static final EventBus BUS = new AsyncEventBus(Executors.newFixedThreadPool(10, r -> {
Thread t = new Thread(r);
t.setName("EventBus-" + UUID.randomUUID().toString().substring(0, 8));
t.setPriority(Thread.NORM_PRIORITY - 1);
return t;
}));
public static void register(EventHandler handler) { public static void register(EventHandler handler) {
if(handlers.containsKey(handler.getId())) { if(handlers.containsKey(handler.getId())) {