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

SequentialScheduler

class SequentialScheduler : Scheduler, TaskQueue

Every task on the thread that posts it, in the order they were posted, those of all queues together: a task posted while another runs waits for it, so that the nodes run in turn, in a deterministic order. A task that fails leaves those after it queued, for the next post.

Constructors

SequentialScheduler

constructor()

Functions

interrupt

open fun interrupt()

The task running now interrupted, where it can be (a thread of the JVM: a resolution halts at its next step), none otherwise

post

open override fun post(task: () -> Unit)

queue

open override fun queue(): TaskQueue