Type Members

1.  trait AbstractAsyncTaskRunner extends DelegatingTaskRunner
2.  trait AbstractCollectionAsyncTaskRunner [A, M[+AA] <: TraversableOnce[AA], MDT <: AbstractCollectionAsyncTaskRunner[A, M, MDT]] extends AbstractAsyncConfigBuilder[MDT]
3.  case class AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
4.  case class CollectionAsyncTaskRunner [A, M[+AA] <: TraversableOnce[AA]](input: M[A], optProgress: Option[ProgressConfig] = None, optRetry: Option[RetryConfig] = None, optThrottle: Option[ThrottleConfig] = None) extends AbstractCollectionAsyncTaskRunner[A, M, CollectionAsyncTaskRunner[A, M]] with Product with Serializable

   A case class for a serial asynchronous task runner that is configurable with optional progress reporting, throttling and/or failure retry.

   A case class for a serial asynchronous task runner that is configurable with optional progress reporting, throttling and/or failure retry.

   A

   the input type

   M

   the collection type

   input

   the input collection

   optProgress

   optional progress reporting settings

   optRetry

   optional failure retry settings

   optThrottle

   optional throttle settings

5.  class ConcurrentTestContextImpl extends ConcurrentTestContext
6.  case class DeferredFutureImpl [A](deferred: Future[Future[A]])(implicit ec: ExecutionContext) extends DeferredFuture[A] with DelegatedFuture[A] with Product with Serializable
7.  trait DelegatingTaskRunner extends TaskRunner
8.  trait FutureOps extends AnyRef
9.  class LatchImpl extends Latch
10.  trait ListQueue [A] extends Queue[A]

    A trait for queue that uses an unlimited size linked list as the backend for the queue.

11.  class ListQueueImpl [A] extends ListQueue[A]

    An implementation of ConcurrentQueue using a ListBuffer backend TODO: explore using a true "concurrent" back end collection that avoids locking TODO: (http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentLinkedQueue.html)

12.  class LockImpl extends Lock

    The default implementation of Lock using a Semaphore backend

13.  trait MergeOps extends AnyRef
14.  case class ParCollectionAsyncTaskRunner [A, M[+AA] <: TraversableOnce[AA]](input: M[A], workerCount: Int = ..., optProgress: Option[ProgressConfig] = None, optRetry: Option[RetryConfig] = None, optThrottle: Option[ThrottleConfig] = None) extends AbstractCollectionAsyncTaskRunner[A, M, ParCollectionAsyncTaskRunner[A, M]] with Product with Serializable

    A case class for a parallel asynchronous task runner that is configurable with optional progress reporting, throttling and/or failure retry.

    A case class for a parallel asynchronous task runner that is configurable with optional progress reporting, throttling and/or failure retry.

    A

    the input type

    M

    the collection type

    input

    the input collection

    optProgress

    optional progress reporting settings

    optRetry

    optional failure retry settings

    optThrottle

    optional throttle settings

15.  class PeriodicProgressReporterImpl extends PeriodicProgressReporter
16.  case class ProgressState (reporter: TaskEventListener)(implicit executionContext: ExecutionContext) extends TaskEventListenerHook with Product with Serializable
17.  trait Queue [A] extends AnyRef

    A trait for a non-blocking queue.

18.  case class RetryState (retryer: RetryDecider) extends TaskStepHook with Product with Serializable
19.  trait SMach_Concurrent_AbstractPimpMyAsyncConfig extends Any
20.  case class ScheduledExecutionContextImpl (delegate: ScheduledExecutorService)(implicit executionContext: ExecutionContext) extends ScheduledExecutionContext with Product with Serializable
21.  abstract class SemaphoreImpl extends Semaphore

    The default implementation of Semaphore using a ListBuffer backend.

    The default implementation of Semaphore using a ListBuffer backend. maxAvailablePermits is not defined and a hook for making new permits available is provided.

22.  class SequencerImpl extends Sequencer
23.  trait SeriallyOps extends AnyRef
24.  class SimpleProgressReporterImpl extends SimpleProgressReporter
25.  case class SimpleRetryDecider (f: (List[Throwable]) ⇒ Future[Boolean])(implicit ec: ExecutionContext) extends RetryDecider with Product with Serializable
26.  trait TaskEventListenerHook extends TaskEventListener with TaskHook with TaskStepHook
27.  trait TaskHook extends AnyRef
28.  trait TaskRunner extends TaskHook with TaskStepHook
29.  trait TaskStepHook extends AnyRef
30.  type TaskStepId = Int
31.  case class ThrottleState (throttle_ns: Long)(implicit scheduledExecutionContext: ScheduledExecutionContext) extends TaskStepHook with Product with Serializable
32.  class ThrottlerImpl extends Throttler
33.  case class Tuple10AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
34.  case class Tuple11AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
35.  case class Tuple12AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
36.  case class Tuple13AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
37.  case class Tuple14AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
38.  case class Tuple15AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
39.  case class Tuple16AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
40.  case class Tuple17AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
41.  case class Tuple18AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
42.  case class Tuple19AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
43.  case class Tuple20AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
44.  case class Tuple21AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
45.  case class Tuple22AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
46.  case class Tuple2AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
47.  case class Tuple3AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
48.  case class Tuple4AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
49.  case class Tuple5AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
50.  case class Tuple6AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
51.  case class Tuple7AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
52.  case class Tuple8AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable
53.  case class Tuple9AsyncTaskRunner (asyncConfig: AsyncConfig) extends AbstractAsyncTaskRunner with Product with Serializable