- java.lang.Object
-
- java.util.concurrent.AbstractExecutorService
-
- java.util.concurrent.ThreadPoolExecutor
-
- com.machinezoo.hookless.ReactiveExecutor
-
- All Implemented Interfaces:
-
Executor
,ExecutorService
@StubDocs public class ReactiveExecutor extends ThreadPoolExecutor
Latency-optimized executor designed for reactive programs.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor
ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy
-
-
Constructor Summary
Constructors Constructor Description ReactiveExecutor()
ReactiveExecutor(int parallelism)
ReactiveExecutor(int parallelism, ThreadFactory threads)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static ReactiveExecutor
common()
static ReactiveExecutor
current()
void
execute(Runnable runnable)
long
getEventCount()
-
Methods inherited from class java.util.concurrent.ThreadPoolExecutor
afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, 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, newTaskFor, submit, submit, submit
-
-
-
-
Constructor Detail
-
ReactiveExecutor
public ReactiveExecutor(int parallelism, ThreadFactory threads)
-
ReactiveExecutor
public ReactiveExecutor(int parallelism)
-
ReactiveExecutor
public ReactiveExecutor()
-
-
Method Detail
-
getEventCount
public long getEventCount()
-
execute
public void execute(Runnable runnable)
- Specified by:
-
execute
in interfaceExecutor
- Overrides:
-
execute
in classThreadPoolExecutor
-
current
public static ReactiveExecutor current()
-
common
public static ReactiveExecutor common()
-
-