diff --git a/common/src/main/java/ctbrec/event/EventBusHolder.java b/common/src/main/java/ctbrec/event/EventBusHolder.java index 6be9ce37..4e0a7a42 100644 --- a/common/src/main/java/ctbrec/event/EventBusHolder.java +++ b/common/src/main/java/ctbrec/event/EventBusHolder.java @@ -2,6 +2,7 @@ package ctbrec.event; import java.util.HashMap; import java.util.Map; +import java.util.UUID; import java.util.concurrent.Executors; import org.slf4j.Logger; @@ -11,10 +12,18 @@ import com.google.common.eventbus.AsyncEventBus; import com.google.common.eventbus.EventBus; 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 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) { if(handlers.containsKey(handler.getId())) {