### Question:
StripedExecutor implements ExecutorService { public int[] stripesQueueSizes() { int[] res = new int[stripesCount()]; for (int i = 0; i < res.length; i++) res[i] = stripes[i].queueSize(); return res; } StripedExecutor(
        int cnt,
        String igniteInstanceName,
        String poolName,
        final IgniteLogger log,
        IgniteInClosure<Throwable> errHnd,
        GridWorkerListener gridWorkerLsnr,
        long failureDetectionTimeout
    );  StripedExecutor(
        int cnt,
        String igniteInstanceName,
        String poolName,
        final IgniteLogger log,
        IgniteInClosure<Throwable> errHnd,
        boolean stealTasks,
        GridWorkerListener gridWorkerLsnr,
        long failureDetectionTimeout
    ); boolean detectStarvation(); int stripesCount(); Stripe[] stripes(); void execute(int idx, Runnable cmd); @Override void shutdown(); @Override void execute(@NotNull Runnable cmd); @NotNull @Override List<Runnable> shutdownNow(); @Override boolean awaitTermination(
        long timeout,
        @NotNull TimeUnit unit
    ); @Override boolean isShutdown(); @Override boolean isTerminated(); void stop(); int queueSize(); int queueSize(int idx); long completedTasks(); long[] stripesCompletedTasks(); boolean[] stripesActiveStatuses(); int activeStripesCount(); int[] stripesQueueSizes(); @NotNull @Override Future<T> submit(
        @NotNull Runnable task,
        T res
    ); @NotNull @Override Future<?> submit(@NotNull Runnable task); @NotNull @Override Future<T> submit(@NotNull Callable<T> task); @NotNull @Override List<Future<T>> invokeAll(@NotNull Collection<? extends Callable<T>> tasks); @NotNull @Override List<Future<T>> invokeAll(
        @NotNull Collection<? extends Callable<T>> tasks,
        long timeout,
        @NotNull TimeUnit unit
    ); @NotNull @Override T invokeAny(@NotNull Collection<? extends Callable<T>> tasks); @Override T invokeAny(
        @NotNull Collection<? extends Callable<T>> tasks,
        long timeout,
        @NotNull TimeUnit unit
    ); void awaitComplete(int... stripes); @Override String toString();  }### Answer:
@Test public void testStripesQueueSizes() throws Exception { stripedExecSvc.execute(0, new TestRunnable()); stripedExecSvc.execute(0, new TestRunnable(true)); stripedExecSvc.execute(0, new TestRunnable(true)); stripedExecSvc.execute(1, new TestRunnable(true)); stripedExecSvc.execute(1, new TestRunnable(true)); stripedExecSvc.execute(1, new TestRunnable(true)); sleepASec(); int[] queueSizes = stripedExecSvc.stripesQueueSizes(); assertEquals(1, queueSizes[0]); assertEquals(2, queueSizes[1]); assertEquals(0, queueSizes[2]); }