Jvm

WorkRunners

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

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)