BusyLoopEventScheduler extends TypedEventScheduler { public int getQueueSize() { return busyLoopQueue.size(); } BusyLoopEventScheduler(
            TimeProvider timeProvider,
            String name,
            EventSchedulerType type,
            ThreadManager threadManager,
            boolean heartbeatMonitor,
            BusyLoopQueueType busyLoopQueueType,
            int size,
            long parkDurationNanos,
            boolean useLowLatencyRunner);  BusyLoopEventScheduler(TimeProvider timeProvider, String name, EventSchedulerType type, ThreadManager threadManager, boolean heartbeatMonitor, long parkDurationNanos, boolean useLowLatencyRunner);  BusyLoopEventScheduler(TimeProvider timeProvider, String name, EventSchedulerType type); @Override void cancel(Event event); @Override TimeProvider getTimeProvider(); @Override Cancelable doNow(Runnable r, String description); @Override Cancelable doAt(double time, Runnable r, String description, boolean isDaemon); void start(); @Override boolean hasOnlyDaemonEvents(); void registerOnShutDown(Runnable onShutDown); void registerFailureListener(Consumer<Throwable> l); void registerRecoverableFailureListener(Consumer<RecoverableException> l); @Override void stop(); @Override long getThreadId(); int getQueueSize();  }
@Test void testGetQueueSize() { Assertions.assertEquals(0, scheduler.getQueueSize()); scheduler.doAt(1000, Runnables.doNothing()); Assertions.assertEquals(1, scheduler.getQueueSize()); }