package b0

  1. Overview
  2. Docs
Software construction and deployment kit

Install 

dune-project
 Dependency

erratique.ch Readme Changelog ISC; BSD-2-Clause License Edit opam file Versions (2)

Authors

  1. T
    The b0 programmers

Maintainers

  1. Daniel Bünzli

Sources

b0-0.0.5.tbz
sha512=00a6868b4dfa34565d0141b335622a81a0e8d5b9e3c6dfad025dabfa3df2db2a1302b492953bbbce30c3a4406c324fcec25250a00b38f6d18a69e15605e3b07e

doc/b0.b00/B000/Exec/index.html

Module B000.Exec

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

type feedback = [
  1. | `Exec_start of B0_std.Os.Cmd.pid option * Op.t
]

The type for executor feedbacks. Indicates the given operation starts executig with, for spawn operations, their operating system process identifier.

type t

The type for executors.

val create : ?clock:B0_std.Os.Mtime.counter -> ?rand:Random.State.t -> ?tmp_dir:B0_std.Fpath.t -> ?feedback:(feedback -> unit) -> trash:Trash.t -> jobs:int -> unit -> t

create ~clock ~rand ~tmp_dir ~feedback ~trash ~jobs with:

  • clock, the clock used to timestamp build operations; defaults to B0_std.Os.Mtime.counter ().
  • rand random state used for internal queues; defaults to Random.State.make_self_init.
  • tmp_dir is a directory for temporary files, it must exist; defaults to B0_std.Os.Dir.default_tmp ().
  • feedback a function called with each scheduled operation when it starts executing. Default is a nop.
  • trash, the trash used to execute B000.Op.Delete build operations.
  • jobs the maximal number of processes spawn simultaneously.
val clock : t -> B0_std.Os.Mtime.counter

clock e is e's clock.

val tmp_dir : t -> B0_std.Fpath.t

tmp_dir e is e's temporary directory.

val trash : t -> Trash.t

trash e is e's trash.

val jobs : t -> int

jobs e is e's maximal number of simultaneous process spawns.

Scheduling and collecting operations

val schedule : t -> Op.t -> unit

schedule e o schedules o for execution in e. When o starts executing it is given to the feedback callback of e (see create).

val collect : t -> block:bool -> Op.t option

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.