class OPALBoundedThreadPoolExecutor extends ThreadPoolExecutor
A ThreadPool that knows the ThreadGroup
associated with its threads and that catches
exceptions if a thread crashes and reports them using the OPALLogger facility.
If the root cause of the exception should be related to the OPALLogger then the error
is written to System.err
.
The pool uses demon threads to make sure that these threads never prevent the JVM from regular termination.
- Alphabetic
- By Inheritance
- OPALBoundedThreadPoolExecutor
- ThreadPoolExecutor
- AbstractExecutorService
- ExecutorService
- AutoCloseable
- Executor
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new OPALBoundedThreadPoolExecutor(n: Int, group: ThreadGroup)
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 afterExecute(r: Runnable, t: Throwable): Unit
- Definition Classes
- OPALBoundedThreadPoolExecutor → ThreadPoolExecutor
- def allowCoreThreadTimeOut(arg0: Boolean): Unit
- Definition Classes
- ThreadPoolExecutor
- def allowsCoreThreadTimeOut(): Boolean
- Definition Classes
- ThreadPoolExecutor
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def awaitTermination(arg0: Long, arg1: TimeUnit): Boolean
- Definition Classes
- ThreadPoolExecutor → ExecutorService
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def beforeExecute(arg0: Thread, arg1: Runnable): Unit
- Attributes
- protected[java.util.concurrent]
- Definition Classes
- ThreadPoolExecutor
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- def close(): Unit
- Definition Classes
- ExecutorService → AutoCloseable
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def execute(arg0: Runnable): Unit
- Definition Classes
- ThreadPoolExecutor → Executor
- def getActiveCount(): Int
- Definition Classes
- ThreadPoolExecutor
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def getCompletedTaskCount(): Long
- Definition Classes
- ThreadPoolExecutor
- def getCorePoolSize(): Int
- Definition Classes
- ThreadPoolExecutor
- def getKeepAliveTime(arg0: TimeUnit): Long
- Definition Classes
- ThreadPoolExecutor
- def getLargestPoolSize(): Int
- Definition Classes
- ThreadPoolExecutor
- def getMaximumPoolSize(): Int
- Definition Classes
- ThreadPoolExecutor
- def getPoolSize(): Int
- Definition Classes
- ThreadPoolExecutor
- def getQueue(): BlockingQueue[Runnable]
- Definition Classes
- ThreadPoolExecutor
- def getRejectedExecutionHandler(): RejectedExecutionHandler
- Definition Classes
- ThreadPoolExecutor
- def getTaskCount(): Long
- Definition Classes
- ThreadPoolExecutor
- def getThreadFactory(): ThreadFactory
- Definition Classes
- ThreadPoolExecutor
- val group: ThreadGroup
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def invokeAll[T <: AnyRef](arg0: Collection[_ <: Callable[T]], arg1: Long, arg2: TimeUnit): List[Future[T]]
- Definition Classes
- AbstractExecutorService → ExecutorService
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def invokeAll[T <: AnyRef](arg0: Collection[_ <: Callable[T]]): List[Future[T]]
- Definition Classes
- AbstractExecutorService → ExecutorService
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def invokeAny[T <: AnyRef](arg0: Collection[_ <: Callable[T]], arg1: Long, arg2: TimeUnit): T
- Definition Classes
- AbstractExecutorService → ExecutorService
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @throws(classOf[java.util.concurrent.ExecutionException]) @throws(classOf[java.util.concurrent.TimeoutException])
- def invokeAny[T <: AnyRef](arg0: Collection[_ <: Callable[T]]): T
- Definition Classes
- AbstractExecutorService → ExecutorService
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @throws(classOf[java.util.concurrent.ExecutionException])
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isShutdown(): Boolean
- Definition Classes
- ThreadPoolExecutor → ExecutorService
- def isTerminated(): Boolean
- Definition Classes
- ThreadPoolExecutor → ExecutorService
- def isTerminating(): Boolean
- Definition Classes
- ThreadPoolExecutor
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def newTaskFor[T <: AnyRef](arg0: Callable[T]): RunnableFuture[T]
- Attributes
- protected[java.util.concurrent]
- Definition Classes
- AbstractExecutorService
- def newTaskFor[T <: AnyRef](arg0: Runnable, arg1: T): RunnableFuture[T]
- Attributes
- protected[java.util.concurrent]
- Definition Classes
- AbstractExecutorService
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def prestartAllCoreThreads(): Int
- Definition Classes
- ThreadPoolExecutor
- def prestartCoreThread(): Boolean
- Definition Classes
- ThreadPoolExecutor
- def purge(): Unit
- Definition Classes
- ThreadPoolExecutor
- def remove(arg0: Runnable): Boolean
- Definition Classes
- ThreadPoolExecutor
- def setCorePoolSize(arg0: Int): Unit
- Definition Classes
- ThreadPoolExecutor
- def setKeepAliveTime(arg0: Long, arg1: TimeUnit): Unit
- Definition Classes
- ThreadPoolExecutor
- def setMaximumPoolSize(arg0: Int): Unit
- Definition Classes
- ThreadPoolExecutor
- def setRejectedExecutionHandler(arg0: RejectedExecutionHandler): Unit
- Definition Classes
- ThreadPoolExecutor
- def setThreadFactory(arg0: ThreadFactory): Unit
- Definition Classes
- ThreadPoolExecutor
- def shutdown(): Unit
- Definition Classes
- ThreadPoolExecutor → ExecutorService
- def shutdownNow(): List[Runnable]
- Definition Classes
- ThreadPoolExecutor → ExecutorService
- def submit[T <: AnyRef](arg0: Callable[T]): Future[T]
- Definition Classes
- AbstractExecutorService → ExecutorService
- def submit[T <: AnyRef](arg0: Runnable, arg1: T): Future[T]
- Definition Classes
- AbstractExecutorService → ExecutorService
- def submit(arg0: Runnable): Future[_ <: AnyRef]
- Definition Classes
- AbstractExecutorService → ExecutorService
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def terminated(): Unit
- Attributes
- protected[java.util.concurrent]
- Definition Classes
- ThreadPoolExecutor
- def toString(): String
- Definition Classes
- ThreadPoolExecutor → 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])
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[java.util.concurrent]
- Definition Classes
- ThreadPoolExecutor → AnyRef
- Annotations
- @Deprecated
- Deprecated