diff --git a/ConfigurationScheduler.java b/ConfigurationScheduler_patched.java index 55cd74a..b5d39d8 100644 --- a/ConfigurationScheduler.java +++ b/ConfigurationScheduler_patched.java @@ -34,7 +34,7 @@ public class ConfigurationScheduler extends AbstractLifeCycle { private static final String SIMPLE_NAME = "Log4j2 " + ConfigurationScheduler.class.getSimpleName(); private static final int MAX_SCHEDULED_ITEMS = 5; - private ScheduledExecutorService executorService; + private ScheduledThreadPoolExecutor executorService; private int scheduledItems = 0; @@ -56,6 +56,7 @@ public class ConfigurationScheduler extends AbstractLifeCycle { setStopping(); if (executorService != null) { LOGGER.debug("{} shutting down threads in {}", SIMPLE_NAME, executorService); + executorService.getQueue().clear(); executorService.shutdown(); } setStopped();