revert(EventExecutor, ModuleExecutorImpl): switch from fixed thread pool to virtual thread executor
This commit is contained in:
@@ -16,7 +16,7 @@ import org.slf4j.LoggerFactory;
|
|||||||
public class EventExecutor {
|
public class EventExecutor {
|
||||||
|
|
||||||
private static final Logger LOGGER = LoggerFactory.getLogger(EventExecutor.class);
|
private static final Logger LOGGER = LoggerFactory.getLogger(EventExecutor.class);
|
||||||
private static final ExecutorService EXECUTOR = Executors.newFixedThreadPool(4); //Executors.newVirtualThreadPerTaskExecutor();
|
private static final ExecutorService EXECUTOR = Executors.newVirtualThreadPerTaskExecutor();
|
||||||
|
|
||||||
private final BlockingQueue<QueuedEvent> eventQueue = new LinkedBlockingQueue<>();
|
private final BlockingQueue<QueuedEvent> eventQueue = new LinkedBlockingQueue<>();
|
||||||
|
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ import org.slf4j.LoggerFactory;
|
|||||||
public class ModuleExecutorImpl implements ModuleExecutor {
|
public class ModuleExecutorImpl implements ModuleExecutor {
|
||||||
|
|
||||||
private static final Logger LOGGER = LoggerFactory.getLogger(ModuleExecutorImpl.class);
|
private static final Logger LOGGER = LoggerFactory.getLogger(ModuleExecutorImpl.class);
|
||||||
private static final ExecutorService EXECUTOR = Executors.newFixedThreadPool(4); // Executors.newVirtualThreadPerTaskExecutor();
|
private static final ExecutorService EXECUTOR = Executors.newVirtualThreadPerTaskExecutor();
|
||||||
|
|
||||||
private final ModuleService moduleManager;
|
private final ModuleService moduleManager;
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user