akka.dispatch

Class BatchingExecutor.BlockableBatch

java.lang.Object

java.util.AbstractCollection<E>

java.util.ArrayDeque<java.lang.Runnable>

akka.dispatch.BatchingExecutor.AbstractBatch

akka.dispatch.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 and Description
BlockableBatch()

Method Summary

Modifier and Type	Method and Description
<T> T	blockOn(scala.Function0<T> thunk, scala.concurrent.CanAwait permission)
void	run()

Methods inherited from class akka.dispatch.BatchingExecutor.AbstractBatch

processBatch, resubmitUnbatched

Methods inherited from class java.util.ArrayDeque

add, addFirst, addLast, clear, clone, contains, descendingIterator, element, getFirst, getLast, isEmpty, iterator, offer, offerFirst, offerLast, peek, peekFirst, peekLast, poll, pollFirst, pollLast, pop, push, remove, remove, removeFirst, removeFirstOccurrence, removeLast, removeLastOccurrence, size, spliterator, toArray, toArray

Methods inherited from class java.util.AbstractCollection

addAll, containsAll, removeAll, retainAll, toString

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface scala.concurrent.BlockContext

current, defaultBlockContext, withBlockContext

Methods inherited from interface java.util.Collection

addAll, containsAll, equals, hashCode, parallelStream, removeAll, removeIf, retainAll, stream

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

BlockableBatch

public BlockableBatch()

Method Detail

run

public final void run()

Specified by:

run in interface java.lang.Runnable

blockOn

public <T> T blockOn(scala.Function0<T> thunk,
                     scala.concurrent.CanAwait permission)

Specified by:

blockOn in interface scala.concurrent.BlockContext