@Override
    public int getQueueSize() {
        // LBQ size handled by an atomic int
        return taskQ.size();
    }
@Test
    public void getQueueSize_whenTaskSubmitted() {
        int queueSize = 10;
        ManagedExecutorService executorService = newManagedExecutorService(1, queueSize);

        CountDownLatch finishLatch = startLongRunningTask(executorService);
        try {
            executeNopTask(executorService);
            assertEquals(1, executorService.getQueueSize());
            assertEquals(1, executorService.getQueueSize());
        } finally {
            finishLatch.countDown();
        }
    }