On This Page
Legend:
Library
Module
Module type
Parameter
Class
Class type
Library
Module
Module type
Parameter
Class
Class type
package b0
On This Page
Legend:
Library
Module
Module type
Parameter
Class
Class type
Library
Module
Module type
Parameter
Class
Class type
Build operation executors.
An executor is a parallel asynchronous work queue. It has no notion of synchronisation, any scheduled operation is randomly executed in parallel up to the executor's parallelizing limits.
Executors
The type for executor feedbacks.
val pp_feedback : feedback B0_std.Fmt.tpp_feedback formats executor feedback.
val create :
?clock:B0_std.Time.counter ->
?rand:Random.State.t ->
?tmp_dir:B0_std.Fpath.t ->
?feedback:(feedback -> unit) ->
max_spawn:int ->
unit ->
tcreate ~clock ~rand ~tmp_dir ~notify_submit ~max_spawn with:
max_spawnthe maximal number of processes spawn simultaneously.feedbackcalled with each scheduled operation when it gets submitted for execution. Default is a nop.tmp_diris a directory for temporary files, it must exist; defaults toB0_std.Os.Dir.default_tmp().randrandom state used for internal queues; defaults toRandom.State.make_self_init.clock, the clock used to timestamp the operations; defaults toB0_std.Time.counter().
schedule e o schedules o for execution in e. Just before o is actually submitted for execution it is given to the notify_submit callback of e (see create).
collect e ~block removes from e an operation that has completed (if any). If block is false and no completed operation exists, the call returns immediately with None. If block is true and at least one incomplete operation exists in e, the call blocks until an operation completes. If block is true and no operation exists in e None is returned.
On This Page