parallel-solver/it.unibo.tuprolog.argumentation.parallel.federation/PoolScheduler

PoolScheduler

class PoolScheduler(threads: Int) : Scheduler, AutoCloseable

The queues run on a pool of threads daemon threads, each queue on one thread at a time: a task that fails is skipped, as an actor resumed on a failure does

Constructors

PoolScheduler

constructor(threads: Int)

Functions

open override fun close()

Stops the threads

queue

open override fun queue(): TaskQueue