ReactiveExecutor (Hookless 0.14.4 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

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.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 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 interface Executor

Overrides:

execute in class ThreadPoolExecutor

current

public static ReactiveExecutor current()

common

public static ReactiveExecutor common()