object AsyncExecutor extends Logging
- Alphabetic
- By Inheritance
- AsyncExecutor
- Logging
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- 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.
- 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.
- 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
- 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.
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- def default(name: String = "AsyncExecutor.default"): AsyncExecutor
- def default(name: String, maxConnections: Int): AsyncExecutor
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- lazy val logger: SlickLogger
- Attributes
- protected[this]
- Definition Classes
- Logging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- case object Continuation extends Priority with Product with Serializable
Continuation is used for database actions that are a continuation of some previously executed actions
- case object Fresh extends Priority with Product with Serializable
Fresh is used for database actions that are scheduled/queued for the first time.
- object PrioritizedRunnable
- 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
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)
edit this text on github
Scala Language-Integrated Connection Kit
This is the API documentation for the Slick database library. It should be used as an additional resource to the user manual.
Further documentation for Slick can be found on the documentation pages.
To the slick package list...