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
- Deprecated