Packages

object AsyncExecutor extends Logging

Source
AsyncExecutor.scala
Linear Supertypes
Logging, AnyRef, Any
Content Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AsyncExecutor
  2. Logging
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. sealed trait PrioritizedRunnable extends Runnable
  2. sealed trait Priority extends AnyRef

Value Members

  1. def apply(name: String, minThreads: Int, maxThreads: Int, queueSize: Int, maxConnections: Int, keepAliveTime: Duration, registerMbeans: Boolean): AsyncExecutor

    Create an AsyncExecutor with a thread pool suitable for blocking I/O.

    Create an AsyncExecutor with a thread pool suitable for blocking I/O. New threads are created as daemon threads.

    name

    A prefix to use for the names of the created threads.

    minThreads

    The number of core threads in the pool.

    maxThreads

    The maximum number of threads in the pool.

    queueSize

    The size of the job queue, 0 for direct hand-off or -1 for unlimited size.

    maxConnections

    The maximum number of configured connections for the connection pool. The underlying ThreadPoolExecutor will not pick up any more work when all connections are in use. It will resume as soon as a connection is released again to the pool

    keepAliveTime

    when the number of threads is greater than the core, this is the maximum time that excess idle threads will wait for new tasks before terminating.

    registerMbeans

    If set to true, register an MXBean that provides insight into the current queue and thread pool workload.

  2. def apply(name: String, minThreads: Int, maxThreads: Int, queueSize: Int, maxConnections: Int, registerMbeans: Boolean): AsyncExecutor

    Create an AsyncExecutor with a thread pool suitable for blocking I/O.

    Create an AsyncExecutor with a thread pool suitable for blocking I/O. New threads are created as daemon threads.

    name

    A prefix to use for the names of the created threads.

    minThreads

    The number of core threads in the pool.

    maxThreads

    The maximum number of threads in the pool.

    queueSize

    The size of the job queue, 0 for direct hand-off or -1 for unlimited size.

    maxConnections

    The maximum number of configured connections for the connection pool. The underlying ThreadPoolExecutor will not pick up any more work when all connections are in use. It will resume as soon as a connection is released again to the pool

    registerMbeans

    If set to true, register an MXBean that provides insight into the current queue and thread pool workload.

  3. def apply(name: String, minThreads: Int, maxThreads: Int, queueSize: Int, maxConnections: Int): AsyncExecutor

    Create an AsyncExecutor with a thread pool suitable for blocking I/O.

    Create an AsyncExecutor with a thread pool suitable for blocking I/O. New threads are created as daemon threads.

    name

    A prefix to use for the names of the created threads.

    minThreads

    The number of core threads in the pool.

    maxThreads

    The maximum number of threads in the pool.

    queueSize

    The size of the job queue, 0 for direct hand-off or -1 for unlimited size.

    maxConnections

    The maximum number of configured connections for the connection pool. The underlying ThreadPoolExecutor will not pick up any more work when all connections are in use. It will resume as soon as a connection is released again to the pool

  4. def apply(name: String, numThreads: Int, queueSize: Int): AsyncExecutor

    Create an AsyncExecutor with a thread pool suitable for blocking I/O.

    Create an AsyncExecutor with a thread pool suitable for blocking I/O. New threads are created as daemon threads.

    name

    A prefix to use for the names of the created threads.

    numThreads

    The number of threads in the pool.

    queueSize

    The size of the job queue, 0 for direct hand-off or -1 for unlimited size.

  5. def default(name: String = "AsyncExecutor.default"): AsyncExecutor
  6. def default(name: String, maxConnections: Int): AsyncExecutor
  7. case object Continuation extends Priority with Product with Serializable

    Continuation is used for database actions that are a continuation of some previously executed actions

  8. case object Fresh extends Priority with Product with Serializable

    Fresh is used for database actions that are scheduled/queued for the first time.

  9. object PrioritizedRunnable
  10. case object WithConnection extends Priority with Product with Serializable

    WithConnection is used for database actions that already have a JDBC connection associated.