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

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
Supertypes
trait Singleton
trait Product
trait Mirror
trait Serializable
trait Product
trait Equals
trait Priority
class Object
trait Matchable
class Any
Show all
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
Supertypes
trait Singleton
trait Product
trait Mirror
trait Serializable
trait Product
trait Equals
trait Priority
class Object
trait Matchable
class Any
Show all
Self type
Fresh.type

Attributes

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

Attributes

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

Attributes

Source
AsyncExecutor.scala
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
Supertypes
trait Singleton
trait Product
trait Mirror
trait Serializable
trait Product
trait Equals
trait Priority
class Object
trait Matchable
class Any
Show all
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.

Value parameters

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.

Attributes

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.

Value parameters

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.

Attributes

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.

Value parameters

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.

Attributes

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.

Value parameters

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.

Attributes

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

Attributes

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

Attributes

Source
AsyncExecutor.scala