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. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. 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.

  5. 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.

  6. 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

  7. 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.

  8. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  9. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
  10. def default(name: String = "AsyncExecutor.default"): AsyncExecutor
  11. def default(name: String, maxConnections: Int): AsyncExecutor
  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  14. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. lazy val logger: SlickLogger
    Attributes
    protected[this]
    Definition Classes
    Logging
  18. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  20. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  21. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  22. def toString(): String
    Definition Classes
    AnyRef → Any
  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  25. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  26. case object Continuation extends Priority with Product with Serializable

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

  27. case object Fresh extends Priority with Product with Serializable

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

  28. object PrioritizedRunnable
  29. case object WithConnection extends Priority with Product with Serializable

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

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped