ScheduledExecutor

org.eso.ias.dasu.executorthread.ScheduledExecutor
See theScheduledExecutor companion object
class ScheduledExecutor(dasuId: String, coreSize: Int) extends ScheduledThreadPoolExecutor

The scheduled executor for the transfer functions of the DASU.

Value parameters

coreSize

the size of the core of the scheduled executor

dasuID

the identifier of the DASU

Attributes

Constructor

Builds the scheduled executor

Companion
object
Graph
Supertypes
class ScheduledThreadPoolExecutor
trait ScheduledExecutorService
class ThreadPoolExecutor
class AbstractExecutorService
trait ExecutorService
trait Executor
class Object
trait Matchable
class Any
Show all

Members list

Value members

Constructors

def this(dasuId: String)

Build a scheduled executor taking the core size from java properties or using the default

Build a scheduled executor taking the core size from java properties or using the default

Attributes

Inherited methods

def allowCoreThreadTimeOut(x$0: Boolean): Unit

Attributes

Inherited from:
ThreadPoolExecutor
def allowsCoreThreadTimeOut(): Boolean

Attributes

Inherited from:
ThreadPoolExecutor
def awaitTermination(x$0: Long, x$1: TimeUnit): Boolean

Attributes

Inherited from:
ThreadPoolExecutor
def execute(x$0: Runnable): Unit

Attributes

Inherited from:
ScheduledThreadPoolExecutor
def getActiveCount(): Int

Attributes

Inherited from:
ThreadPoolExecutor
def getCompletedTaskCount(): Long

Attributes

Inherited from:
ThreadPoolExecutor

Attributes

Inherited from:
ScheduledThreadPoolExecutor
def getCorePoolSize(): Int

Attributes

Inherited from:
ThreadPoolExecutor

Attributes

Inherited from:
ScheduledThreadPoolExecutor
def getKeepAliveTime(x$0: TimeUnit): Long

Attributes

Inherited from:
ThreadPoolExecutor
def getLargestPoolSize(): Int

Attributes

Inherited from:
ThreadPoolExecutor
def getMaximumPoolSize(): Int

Attributes

Inherited from:
ThreadPoolExecutor
def getPoolSize(): Int

Attributes

Inherited from:
ThreadPoolExecutor
def getQueue(): BlockingQueue[Runnable]

Attributes

Inherited from:
ScheduledThreadPoolExecutor
def getRejectedExecutionHandler(): RejectedExecutionHandler

Attributes

Inherited from:
ThreadPoolExecutor
def getRemoveOnCancelPolicy(): Boolean

Attributes

Inherited from:
ScheduledThreadPoolExecutor
def getTaskCount(): Long

Attributes

Inherited from:
ThreadPoolExecutor
def getThreadFactory(): ThreadFactory

Attributes

Inherited from:
ThreadPoolExecutor
def invokeAll[T <: <FromJavaObject>](x$0: Collection[_ <: Callable[T]], x$1: Long, x$2: TimeUnit): List[Future[T]]

Attributes

Inherited from:
AbstractExecutorService
def invokeAll[T <: <FromJavaObject>](x$0: Collection[_ <: Callable[T]]): List[Future[T]]

Attributes

Inherited from:
AbstractExecutorService
def invokeAny[T <: <FromJavaObject>](x$0: Collection[_ <: Callable[T]], x$1: Long, x$2: TimeUnit): T

Attributes

Inherited from:
AbstractExecutorService
def invokeAny[T <: <FromJavaObject>](x$0: Collection[_ <: Callable[T]]): T

Attributes

Inherited from:
AbstractExecutorService
def isShutdown(): Boolean

Attributes

Inherited from:
ThreadPoolExecutor
def isTerminated(): Boolean

Attributes

Inherited from:
ThreadPoolExecutor
def isTerminating(): Boolean

Attributes

Inherited from:
ThreadPoolExecutor

Attributes

Inherited from:
ThreadPoolExecutor
def prestartCoreThread(): Boolean

Attributes

Inherited from:
ThreadPoolExecutor
def purge(): Unit

Attributes

Inherited from:
ThreadPoolExecutor
def remove(x$0: Runnable): Boolean

Attributes

Inherited from:
ThreadPoolExecutor
def schedule[V <: <FromJavaObject>](x$0: Callable[V], x$1: Long, x$2: TimeUnit): ScheduledFuture[V]

Attributes

Inherited from:
ScheduledThreadPoolExecutor
def schedule(x$0: Runnable, x$1: Long, x$2: TimeUnit): ScheduledFuture[_ <: <FromJavaObject>]

Attributes

Inherited from:
ScheduledThreadPoolExecutor
def scheduleAtFixedRate(x$0: Runnable, x$1: Long, x$2: Long, x$3: TimeUnit): ScheduledFuture[_ <: <FromJavaObject>]

Attributes

Inherited from:
ScheduledThreadPoolExecutor
def scheduleWithFixedDelay(x$0: Runnable, x$1: Long, x$2: Long, x$3: TimeUnit): ScheduledFuture[_ <: <FromJavaObject>]

Attributes

Inherited from:
ScheduledThreadPoolExecutor

Attributes

Inherited from:
ScheduledThreadPoolExecutor
def setCorePoolSize(x$0: Int): Unit

Attributes

Inherited from:
ThreadPoolExecutor

Attributes

Inherited from:
ScheduledThreadPoolExecutor
def setKeepAliveTime(x$0: Long, x$1: TimeUnit): Unit

Attributes

Inherited from:
ThreadPoolExecutor
def setMaximumPoolSize(x$0: Int): Unit

Attributes

Inherited from:
ThreadPoolExecutor
def setRejectedExecutionHandler(x$0: RejectedExecutionHandler): Unit

Attributes

Inherited from:
ThreadPoolExecutor
def setRemoveOnCancelPolicy(x$0: Boolean): Unit

Attributes

Inherited from:
ScheduledThreadPoolExecutor
def setThreadFactory(x$0: ThreadFactory): Unit

Attributes

Inherited from:
ThreadPoolExecutor
def shutdown(): Unit

Attributes

Inherited from:
ScheduledThreadPoolExecutor
def shutdownNow(): List[Runnable]

Attributes

Inherited from:
ScheduledThreadPoolExecutor
def submit[T <: <FromJavaObject>](x$0: Callable[T]): Future[T]

Attributes

Inherited from:
ScheduledThreadPoolExecutor
def submit[T <: <FromJavaObject>](x$0: Runnable, x$1: T): Future[T]

Attributes

Inherited from:
ScheduledThreadPoolExecutor
def submit(x$0: Runnable): Future[_ <: <FromJavaObject>]

Attributes

Inherited from:
ScheduledThreadPoolExecutor
def toString(): String

Returns a string representation of the object.

Returns a string representation of the object.

The default representation is platform dependent.

Attributes

Returns

a string representation of the object.

Inherited from:
ThreadPoolExecutor