test_class.declarator: stripedExecSvc
test_class.modifier: private
test_class.original_string: private StripedExecutor stripedExecSvc;
test_class.type: StripedExecutor
test_class.var_name: stripedExecSvc
test_class.file: modules/core/src/test/java/org/apache/ignite/internal/util/StripedExecutorTest.java
test_class.identifier: StripedExecutorTest
test_class.superclass: extends GridCommonAbstractTest
test_case.body: @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]);
      }
test_case.class_method_signature: StripedExecutorTest.testStripesQueueSizes()
test_case.full_signature: @Test public void testStripesQueueSizes()
test_case.identifier: testStripesQueueSizes
test_case.invocations: execute execute execute execute execute execute sleepASec stripesQueueSizes assertEquals assertEquals assertEquals
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testStripesQueueSizes()
focal_class.declarator: stripes
focal_class.modifier: private final
focal_class.original_string: private final Stripe[] stripes;
focal_class.type: Stripe[]
focal_class.var_name: stripes
focal_class.declarator: threshold
focal_class.modifier: private final
focal_class.original_string: private final long threshold;
focal_class.type: long
focal_class.var_name: threshold
focal_class.declarator: log
focal_class.modifier: private final
focal_class.original_string: private final IgniteLogger log;
focal_class.type: IgniteLogger
focal_class.var_name: log
focal_class.file: modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java
focal_class.identifier: StripedExecutor
focal_class.interfaces: implements ExecutorService
focal_class.class_method_signature: StripedExecutor.StripedExecutor(
          int cnt,
          String igniteInstanceName,
          String poolName,
          final IgniteLogger log,
          IgniteInClosure<Throwable> errHnd,
          GridWorkerListener gridWorkerLsnr,
          long failureDetectionTimeout
      )
focal_class.full_signature: public  StripedExecutor(
          int cnt,
          String igniteInstanceName,
          String poolName,
          final IgniteLogger log,
          IgniteInClosure<Throwable> errHnd,
          GridWorkerListener gridWorkerLsnr,
          long failureDetectionTimeout
      )
focal_class.identifier: StripedExecutor
focal_class.modifiers: public
focal_class.parameters: (
          int cnt,
          String igniteInstanceName,
          String poolName,
          final IgniteLogger log,
          IgniteInClosure<Throwable> errHnd,
          GridWorkerListener gridWorkerLsnr,
          long failureDetectionTimeout
      )
focal_class.signature:  StripedExecutor(
          int cnt,
          String igniteInstanceName,
          String poolName,
          final IgniteLogger log,
          IgniteInClosure<Throwable> errHnd,
          GridWorkerListener gridWorkerLsnr,
          long failureDetectionTimeout
      )
focal_class.class_method_signature: StripedExecutor.StripedExecutor(
          int cnt,
          String igniteInstanceName,
          String poolName,
          final IgniteLogger log,
          IgniteInClosure<Throwable> errHnd,
          boolean stealTasks,
          GridWorkerListener gridWorkerLsnr,
          long failureDetectionTimeout
      )
focal_class.full_signature: public  StripedExecutor(
          int cnt,
          String igniteInstanceName,
          String poolName,
          final IgniteLogger log,
          IgniteInClosure<Throwable> errHnd,
          boolean stealTasks,
          GridWorkerListener gridWorkerLsnr,
          long failureDetectionTimeout
      )
focal_class.identifier: StripedExecutor
focal_class.modifiers: public
focal_class.parameters: (
          int cnt,
          String igniteInstanceName,
          String poolName,
          final IgniteLogger log,
          IgniteInClosure<Throwable> errHnd,
          boolean stealTasks,
          GridWorkerListener gridWorkerLsnr,
          long failureDetectionTimeout
      )
focal_class.signature:  StripedExecutor(
          int cnt,
          String igniteInstanceName,
          String poolName,
          final IgniteLogger log,
          IgniteInClosure<Throwable> errHnd,
          boolean stealTasks,
          GridWorkerListener gridWorkerLsnr,
          long failureDetectionTimeout
      )
focal_class.class_method_signature: StripedExecutor.detectStarvation()
focal_class.full_signature: public boolean detectStarvation()
focal_class.identifier: detectStarvation
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean detectStarvation()
focal_class.class_method_signature: StripedExecutor.stripesCount()
focal_class.full_signature: public int stripesCount()
focal_class.identifier: stripesCount
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int stripesCount()
focal_class.class_method_signature: StripedExecutor.stripes()
focal_class.full_signature: public Stripe[] stripes()
focal_class.identifier: stripes
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Stripe[]
focal_class.signature: Stripe[] stripes()
focal_class.class_method_signature: StripedExecutor.execute(int idx, Runnable cmd)
focal_class.full_signature: public void execute(int idx, Runnable cmd)
focal_class.identifier: execute
focal_class.modifiers: public
focal_class.parameters: (int idx, Runnable cmd)
focal_class.return: void
focal_class.signature: void execute(int idx, Runnable cmd)
focal_class.class_method_signature: StripedExecutor.shutdown()
focal_class.full_signature: @Override public void shutdown()
focal_class.identifier: shutdown
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void shutdown()
focal_class.class_method_signature: StripedExecutor.execute(@NotNull Runnable cmd)
focal_class.full_signature: @Override public void execute(@NotNull Runnable cmd)
focal_class.identifier: execute
focal_class.modifiers: @Override public
focal_class.parameters: (@NotNull Runnable cmd)
focal_class.return: void
focal_class.signature: void execute(@NotNull Runnable cmd)
focal_class.class_method_signature: StripedExecutor.shutdownNow()
focal_class.full_signature: @NotNull @Override public List<Runnable> shutdownNow()
focal_class.identifier: shutdownNow
focal_class.modifiers: @NotNull @Override public
focal_class.parameters: ()
focal_class.return: List<Runnable>
focal_class.signature: List<Runnable> shutdownNow()
focal_class.class_method_signature: StripedExecutor.awaitTermination(
          long timeout,
          @NotNull TimeUnit unit
      )
focal_class.full_signature: @Override public boolean awaitTermination(
          long timeout,
          @NotNull TimeUnit unit
      )
focal_class.identifier: awaitTermination
focal_class.modifiers: @Override public
focal_class.parameters: (
          long timeout,
          @NotNull TimeUnit unit
      )
focal_class.return: boolean
focal_class.signature: boolean awaitTermination(
          long timeout,
          @NotNull TimeUnit unit
      )
focal_class.class_method_signature: StripedExecutor.isShutdown()
focal_class.full_signature: @Override public boolean isShutdown()
focal_class.identifier: isShutdown
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isShutdown()
focal_class.class_method_signature: StripedExecutor.isTerminated()
focal_class.full_signature: @Override public boolean isTerminated()
focal_class.identifier: isTerminated
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isTerminated()
focal_class.class_method_signature: StripedExecutor.stop()
focal_class.full_signature: public void stop()
focal_class.identifier: stop
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void stop()
focal_class.class_method_signature: StripedExecutor.signalStop()
focal_class.full_signature: private void signalStop()
focal_class.identifier: signalStop
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void signalStop()
focal_class.class_method_signature: StripedExecutor.awaitStop()
focal_class.full_signature: private void awaitStop()
focal_class.identifier: awaitStop
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void awaitStop()
focal_class.class_method_signature: StripedExecutor.queueSize()
focal_class.full_signature: public int queueSize()
focal_class.identifier: queueSize
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int queueSize()
focal_class.class_method_signature: StripedExecutor.queueSize(int idx)
focal_class.full_signature: public int queueSize(int idx)
focal_class.identifier: queueSize
focal_class.modifiers: public
focal_class.parameters: (int idx)
focal_class.return: int
focal_class.signature: int queueSize(int idx)
focal_class.class_method_signature: StripedExecutor.completedTasks()
focal_class.full_signature: public long completedTasks()
focal_class.identifier: completedTasks
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long completedTasks()
focal_class.class_method_signature: StripedExecutor.stripesCompletedTasks()
focal_class.full_signature: public long[] stripesCompletedTasks()
focal_class.identifier: stripesCompletedTasks
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: long[]
focal_class.signature: long[] stripesCompletedTasks()
focal_class.class_method_signature: StripedExecutor.stripesActiveStatuses()
focal_class.full_signature: public boolean[] stripesActiveStatuses()
focal_class.identifier: stripesActiveStatuses
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean[]
focal_class.signature: boolean[] stripesActiveStatuses()
focal_class.class_method_signature: StripedExecutor.activeStripesCount()
focal_class.full_signature: public int activeStripesCount()
focal_class.identifier: activeStripesCount
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int activeStripesCount()
focal_class.class_method_signature: StripedExecutor.stripesQueueSizes()
focal_class.full_signature: public int[] stripesQueueSizes()
focal_class.identifier: stripesQueueSizes
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int[]
focal_class.signature: int[] stripesQueueSizes()
focal_class.class_method_signature: StripedExecutor.submit(
          @NotNull Runnable task,
          T res
      )
focal_class.full_signature: @NotNull @Override public Future<T> submit(
          @NotNull Runnable task,
          T res
      )
focal_class.identifier: submit
focal_class.modifiers: @NotNull @Override public
focal_class.parameters: (
          @NotNull Runnable task,
          T res
      )
focal_class.return: Future<T>
focal_class.signature: Future<T> submit(
          @NotNull Runnable task,
          T res
      )
focal_class.class_method_signature: StripedExecutor.submit(@NotNull Runnable task)
focal_class.full_signature: @NotNull @Override public Future<?> submit(@NotNull Runnable task)
focal_class.identifier: submit
focal_class.modifiers: @NotNull @Override public
focal_class.parameters: (@NotNull Runnable task)
focal_class.return: Future<?>
focal_class.signature: Future<?> submit(@NotNull Runnable task)
focal_class.class_method_signature: StripedExecutor.submit(@NotNull Callable<T> task)
focal_class.full_signature: @NotNull @Override public Future<T> submit(@NotNull Callable<T> task)
focal_class.identifier: submit
focal_class.modifiers: @NotNull @Override public
focal_class.parameters: (@NotNull Callable<T> task)
focal_class.return: Future<T>
focal_class.signature: Future<T> submit(@NotNull Callable<T> task)
focal_class.class_method_signature: StripedExecutor.invokeAll(@NotNull Collection<? extends Callable<T>> tasks)
focal_class.full_signature: @NotNull @Override public List<Future<T>> invokeAll(@NotNull Collection<? extends Callable<T>> tasks)
focal_class.identifier: invokeAll
focal_class.modifiers: @NotNull @Override public
focal_class.parameters: (@NotNull Collection<? extends Callable<T>> tasks)
focal_class.return: List<Future<T>>
focal_class.signature: List<Future<T>> invokeAll(@NotNull Collection<? extends Callable<T>> tasks)
focal_class.class_method_signature: StripedExecutor.invokeAll(
          @NotNull Collection<? extends Callable<T>> tasks,
          long timeout,
          @NotNull TimeUnit unit
      )
focal_class.full_signature: @NotNull @Override public List<Future<T>> invokeAll(
          @NotNull Collection<? extends Callable<T>> tasks,
          long timeout,
          @NotNull TimeUnit unit
      )
focal_class.identifier: invokeAll
focal_class.modifiers: @NotNull @Override public
focal_class.parameters: (
          @NotNull Collection<? extends Callable<T>> tasks,
          long timeout,
          @NotNull TimeUnit unit
      )
focal_class.return: List<Future<T>>
focal_class.signature: List<Future<T>> invokeAll(
          @NotNull Collection<? extends Callable<T>> tasks,
          long timeout,
          @NotNull TimeUnit unit
      )
focal_class.class_method_signature: StripedExecutor.invokeAny(@NotNull Collection<? extends Callable<T>> tasks)
focal_class.full_signature: @NotNull @Override public T invokeAny(@NotNull Collection<? extends Callable<T>> tasks)
focal_class.identifier: invokeAny
focal_class.modifiers: @NotNull @Override public
focal_class.parameters: (@NotNull Collection<? extends Callable<T>> tasks)
focal_class.return: T
focal_class.signature: T invokeAny(@NotNull Collection<? extends Callable<T>> tasks)
focal_class.class_method_signature: StripedExecutor.invokeAny(
          @NotNull Collection<? extends Callable<T>> tasks,
          long timeout,
          @NotNull TimeUnit unit
      )
focal_class.full_signature: @Override public T invokeAny(
          @NotNull Collection<? extends Callable<T>> tasks,
          long timeout,
          @NotNull TimeUnit unit
      )
focal_class.identifier: invokeAny
focal_class.modifiers: @Override public
focal_class.parameters: (
          @NotNull Collection<? extends Callable<T>> tasks,
          long timeout,
          @NotNull TimeUnit unit
      )
focal_class.return: T
focal_class.signature: T invokeAny(
          @NotNull Collection<? extends Callable<T>> tasks,
          long timeout,
          @NotNull TimeUnit unit
      )
focal_class.class_method_signature: StripedExecutor.awaitComplete(int... stripes)
focal_class.full_signature: public void awaitComplete(int... stripes)
focal_class.identifier: awaitComplete
focal_class.modifiers: public
focal_class.parameters: (int... stripes)
focal_class.return: void
focal_class.signature: void awaitComplete(int... stripes)
focal_class.class_method_signature: StripedExecutor.toString()
focal_class.full_signature: @Override public String toString()
focal_class.identifier: toString
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String toString()
focal_method.body: public int[] stripesQueueSizes() {
          int[] res = new int[stripesCount()];
  
          for (int i = 0; i < res.length; i++)
              res[i] = stripes[i].queueSize();
  
          return res;
      }
focal_method.class_method_signature: StripedExecutor.stripesQueueSizes()
focal_method.full_signature: public int[] stripesQueueSizes()
focal_method.identifier: stripesQueueSizes
focal_method.invocations: stripesCount queueSize
focal_method.modifiers: public
focal_method.parameters: ()
focal_method.return: int[]
focal_method.signature: int[] stripesQueueSizes()