Object/Trait

slick.util

AsyncExecutor

Related Docs: trait AsyncExecutor | package util

Permalink

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

Type Members

  1. trait PrioritizedRunnable extends Runnable

    Permalink
  2. sealed trait Priority extends AnyRef

    Permalink

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. object Continuation extends Priority with Product with Serializable

    Permalink

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

  5. object Fresh extends Priority with Product with Serializable

    Permalink

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

  6. object WithConnection extends Priority with Product with Serializable

    Permalink

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

  7. def apply(name: String, minThreads: Int, maxThreads: Int, queueSize: Int, maxConnections: Int = Integer.MAX_VALUE, keepAliveTime: Duration = 1.minute): AsyncExecutor

    Permalink

    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 Default is Integer.MAX_VALUE which is only ever a good choice when not using connection pooling

    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.

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

    Permalink

    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.

  9. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  10. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  11. def default(name: String = "AsyncExecutor.default"): AsyncExecutor

    Permalink
  12. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  13. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  14. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  15. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  16. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  17. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  18. lazy val logger: SlickLogger

    Permalink
    Attributes
    protected[this]
    Definition Classes
    Logging
  19. val loggingReporter: (Throwable) ⇒ Unit

    Permalink
  20. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  21. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  22. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  23. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  24. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  25. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  26. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  27. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped