@Test public void testCompletedTasks() throws Exception { stripedExecSvc.execute(0, new TestRunnable()); stripedExecSvc.execute(1, new TestRunnable()); sleepASec(); assertEquals(2, stripedExecSvc.completedTasks()); }
public long completedTasks() { long cnt = 0; for (Stripe stripe : stripes) cnt += stripe.completedCnt; return cnt; }
StripedExecutor implements ExecutorService { public long completedTasks() { long cnt = 0; for (Stripe stripe : stripes) cnt += stripe.completedCnt; return cnt; } }
StripedExecutor implements ExecutorService { public long completedTasks() { long cnt = 0; for (Stripe stripe : stripes) cnt += stripe.completedCnt; return cnt; } 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
    ); }
StripedExecutor implements ExecutorService { public long completedTasks() { long cnt = 0; for (Stripe stripe : stripes) cnt += stripe.completedCnt; return cnt; } 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(); }
StripedExecutor implements ExecutorService { public long completedTasks() { long cnt = 0; for (Stripe stripe : stripes) cnt += stripe.completedCnt; return cnt; } 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();  }