site/com.avast.sst.jvm.execution

com.avast.sst.jvm.execution

package com.avast.sst.jvm.execution

Type members

Classlikes

class ConfigurableThreadFactory(config: Config) extends ThreadFactory with ForkJoinWorkerThreadFactory

Thread factory (both java.util.concurrent.ThreadFactory and java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory) that creates new threads according to the provided com.avast.sst.jvm.execution.ConfigurableThreadFactory.Config.

Thread factory (both java.util.concurrent.ThreadFactory and java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory) that creates new threads according to the provided com.avast.sst.jvm.execution.ConfigurableThreadFactory.Config.

Companion:
object
object ConfigurableThreadFactory
Companion:
class
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.

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
object ExecutorModule
Companion:
class
final case class ForkJoinPoolConfig(parallelismMin: Int, parallelismFactor: Double, parallelismMax: Int, taskPeekingMode: TaskPeekingMode)
Companion:
object
object ForkJoinPoolConfig
Companion:
class
object LoggingUncaughtExceptionHandler extends UncaughtExceptionHandler
final case class ThreadPoolExecutorConfig(coreSize: Int, maxSize: Int, keepAlive: FiniteDuration, allowCoreThreadTimeout: Boolean)