site/com.avast.sst.jvm.execution/ExecutorModule

ExecutorModule

class ExecutorModule[F[_]](val numOfCpus: Int, val executionContext: ExecutionContext, blockingExecutor: ExecutionContextExecutorService)(using evidence$1: Sync[F])

Provides necessary executors - the default one for execution of your business logic and callbacks and special one designated for blocking operations. Also allows you to create more executors if you need them.

Companion:
object
class Object
trait Matchable
class Any

Type members

Classlikes

object Implicits

Provides implicit reference to the default callback executor for easier use.

Provides implicit reference to the default callback executor for easier use.

Value members

Concrete methods

def makeForkJoinPool(config: ForkJoinPoolConfig, threadFactory: ForkJoinWorkerThreadFactory): Resource[F, ForkJoinPool]

Makes ForkJoinPool according to the given config and with java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory.

Makes ForkJoinPool according to the given config and with java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory.

def makeThreadPoolExecutor(config: ThreadPoolExecutorConfig, threadFactory: ThreadFactory): Resource[F, ThreadPoolExecutor]

Makes java.util.concurrent.ThreadPoolExecutor according to the given config and with java.util.concurrent.ThreadFactory.

Makes java.util.concurrent.ThreadPoolExecutor according to the given config and with java.util.concurrent.ThreadFactory.

Concrete fields

val blocker: Blocker

Executor designated for blocking operations.

Executor designated for blocking operations.

val blockingExecutorService: ExecutorService

java.util.concurrent.ExecutorService that can be used for blocking operations in Java-interop code.

java.util.concurrent.ExecutorService that can be used for blocking operations in Java-interop code.

val executionContext: ExecutionContext
val numOfCpus: Int