Package akka.dispatch

Class BatchingExecutor.BlockableBatch

  • All Implemented Interfaces:
    java.io.Serializable, java.lang.Cloneable, java.lang.Iterable<java.lang.Runnable>, java.lang.Runnable, java.util.Collection<java.lang.Runnable>, java.util.Deque<java.lang.Runnable>, java.util.Queue<java.lang.Runnable>, scala.concurrent.BlockContext
    Enclosing interface:
    BatchingExecutor

    public private static final class BatchingExecutor.BlockableBatch
    extends BatchingExecutor.AbstractBatch
    implements scala.concurrent.BlockContext
    See Also:
    Serialized Form
    • Nested Class Summary

      • Nested classes/interfaces inherited from interface scala.concurrent.BlockContext

        scala.concurrent.BlockContext.DefaultBlockContext$
    • Constructor Summary

      Constructors 
      Constructor Description
      BlockableBatch()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T> T blockOn​(scala.Function0<T> thunk, scala.concurrent.CanAwait permission)  
      void run()  
      • Methods inherited from class java.util.ArrayDeque

        add, addAll, addFirst, addLast, clear, clone, contains, descendingIterator, element, forEach, getFirst, getLast, isEmpty, iterator, offer, offerFirst, offerLast, peek, peekFirst, peekLast, poll, pollFirst, pollLast, pop, push, remove, remove, removeAll, removeFirst, removeFirstOccurrence, removeIf, removeLast, removeLastOccurrence, retainAll, size, spliterator, toArray, toArray
      • Methods inherited from class java.util.AbstractCollection

        containsAll, toString
      • Methods inherited from class java.lang.Object

        equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
      • Methods inherited from interface java.util.Collection

        containsAll, equals, hashCode, parallelStream, stream, toArray
    • Constructor Detail

      • BlockableBatch

        public BlockableBatch()
    • Method Detail

      • blockOn

        public <T> T blockOn​(scala.Function0<T> thunk,
                             scala.concurrent.CanAwait permission)
        Specified by:
        blockOn in interface scala.concurrent.BlockContext
      • run

        public final void run()
        Specified by:
        run in interface java.lang.Runnable