ReactiveExecutor (Hookless 0.16.1 API)

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

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

Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details
- ReactiveExecutor
  
  public ReactiveExecutor(int parallelism, ThreadFactory threads)
- ReactiveExecutor
  
  public ReactiveExecutor(int parallelism)
- ReactiveExecutor
  
  public ReactiveExecutor()
Method Details
- getEventCount
  
  public long getEventCount()
- execute
  
  public void execute(Runnable runnable)
  
  Specified by:
  
  execute in interface Executor
  
  Overrides:
  
  execute in class ThreadPoolExecutor
- current
  
  public static ReactiveExecutor current()
- common
  
  public static ReactiveExecutor common()

Class ReactiveExecutor

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

Constructor Summary

Method Summary

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

Methods inherited from class java.util.concurrent.AbstractExecutorService

Methods inherited from class java.lang.Object

Constructor Details

ReactiveExecutor

ReactiveExecutor

ReactiveExecutor

Method Details

getEventCount

execute

current

common