AsyncExecutor

slick.util.AsyncExecutor$
See theAsyncExecutor companion trait
object AsyncExecutor extends Logging

Attributes

Companion:
trait
Source:
AsyncExecutor.scala
Graph
Supertypes
trait Logging
class Object
trait Matchable
class Any
Self type

Members list

Concise view

Type members

Classlikes

case object Continuation extends Priority

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

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

Attributes

Source:
AsyncExecutor.scala
Graph
Supertypes
trait Singleton
trait Product
trait Mirror
trait Serializable
trait Product
trait Equals
trait Priority
class Object
trait Matchable
class Any
Self type
case object Fresh extends Priority

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

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

Attributes

Source:
AsyncExecutor.scala
Graph
Supertypes
trait Singleton
trait Product
trait Mirror
trait Serializable
trait Product
trait Equals
trait Priority
class Object
trait Matchable
class Any
Self type
Fresh.type

Attributes

Companion:
trait
Source:
AsyncExecutor.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Self type
sealed trait PrioritizedRunnable extends Runnable

Attributes

Companion:
object
Source:
AsyncExecutor.scala
Graph
Supertypes
trait Runnable
class Object
trait Matchable
class Any
sealed trait Priority

Attributes

Source:
AsyncExecutor.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes
object Continuation.type
object Fresh.type
object WithConnection.type
case object WithConnection extends Priority

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

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

Attributes

Source:
AsyncExecutor.scala
Graph
Supertypes
trait Singleton
trait Product
trait Mirror
trait Serializable
trait Product
trait Equals
trait Priority
class Object
trait Matchable
class Any
Self type

Value members

Concrete methods

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

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

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

Attributes

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.

Source:
AsyncExecutor.scala
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. New threads are created as daemon threads.

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

Attributes

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

maxThreads

The maximum number of threads in the pool.

minThreads

The number of core threads in the pool.

name

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

queueSize

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

Source:
AsyncExecutor.scala
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. New threads are created as daemon threads.

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

Attributes

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

maxThreads

The maximum number of threads in the pool.

minThreads

The number of core threads in the pool.

name

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

queueSize

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

registerMbeans

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

Source:
AsyncExecutor.scala
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. New threads are created as daemon threads.

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

Attributes

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.

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

maxThreads

The maximum number of threads in the pool.

minThreads

The number of core threads in the pool.

name

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

queueSize

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

registerMbeans

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

Source:
AsyncExecutor.scala
def default(name: String, maxConnections: Int): AsyncExecutor

Attributes

Source:
AsyncExecutor.scala
def default(name: String): AsyncExecutor

Attributes

Source:
AsyncExecutor.scala