Module Duppy.Task

Core task registration. * * A task will be a set of events to watch, and a corresponding function to * execute when one of the events is triggered. * * The executed function may then return a list of new tasks to schedule.

type ('a, 'b) task = {
  1. priority : 'a;
  2. events : 'b list;
  3. handler : 'b list -> ('a, 'b) task list;
}

A task is a list of events awaited, * and a function to process events that have occurred. * * The 'a parameter is the type of priorities, 'b will be a subset of possible * events.

type event = [
  1. | `Delay of float
  2. | `Write of Unix.file_descr
  3. | `Read of Unix.file_descr
]

Type for possible events. * * Please not that currently, under win32, all socket used in ocaml-duppy * are expected to be in blocking mode only!

val add : ?domain:int -> 'a scheduler -> ('a, [< event ]) task -> unit

Schedule a task. With domain, only the worker on that domain runs it, and so does every task its handler returns. Raises Unknown_domain when no started worker is on that domain or accepts the task's priority, and always on a thread pool, where workers share a domain.