Package com.seeq.link.sdk.export
Class ExportTaskScheduler
java.lang.Object
java.util.concurrent.AbstractExecutorService
java.util.concurrent.ThreadPoolExecutor
com.seeq.link.sdk.export.ExportTaskScheduler
- All Implemented Interfaces:
AutoCloseable
,Executor
,ExecutorService
Extends ThreadPoolExecutor to have three named queues (fast, normal, slow).
-
Nested Class Summary
Nested ClassesNested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor
ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
protected <T> RunnableFuture<T>
newTaskFor
(Runnable runnable, T value) Future<?>
queueTask
(ExportTask task, ExportTaskScheduler.Queue queue) Methods inherited from class java.util.concurrent.ThreadPoolExecutor
afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, execute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, terminated, toString
Methods inherited from class java.util.concurrent.AbstractExecutorService
invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, submit, submit, submit
-
Constructor Details
-
ExportTaskScheduler
public ExportTaskScheduler(int maxConcurrencyLevel)
-
-
Method Details
-
queueTask
-
newTaskFor
- Overrides:
newTaskFor
in classAbstractExecutorService
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
-