Jvm

WorkRunners

Various factories are provided for java.util.concurrent.ExecutorService.

Default WorkRunners

Jvm targets will use a single thread for Events and a cached thread pool for Effects.

See Configuration to change the default WorkRunners.

Single Thread

val workRunner = WorkRunners.singleThread()

Fixed Thread Pool

val workRunner = WorkRunners.fixedThreadPool(n = 2)

Cached Thread Pool

val workRunner = WorkRunners.cachedThreadPool()

Existing ExecutorService

If you have an existing ExecutorService, you can wrap it with WorkRunners.from(service)

val myExecutor = Executors.newSingleThreadExecutor()
val workRunner = WorkRunners.from(myExecutor)