Class CacheStripedExecutor


  • public class CacheStripedExecutor
    extends Object
    Wrapper over StripedExecutor, that groups submitted tasks by cache group and partition.
    • Constructor Detail

      • CacheStripedExecutor

        public CacheStripedExecutor​(StripedExecutor exec)
    • Method Detail

      • submit

        public void submit​(Runnable task,
                           int grpId,
                           int partId)
        Submit task to striped executor.
        Parameters:
        task - Runnable task.
        grpId - Group ID.
        partId - Partition ID.
      • error

        public boolean error()
        Returns:
        true if any of submitted tasks failed.
      • onError

        public void onError​(IgniteCheckedException e)
        Parameters:
        e - Error appeared during submitted task execution.
      • executor

        public StripedExecutor executor()
        Returns:
        Underlying striped executor.