impl

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