package devkit

  1. Overview
  2. Docs
Development kit - general purpose library

Install

Dune Dependency

Authors

Maintainers

Sources

devkit-1.20240429.tbz
sha256=222f8ac131b1d970dab7eeb2714bfd6b9338b88b1082e6e01c136ae19e7eaef4
sha512=c9e6d93e3d21e5530c0f4d5baca51bf1f0a5d19248f8af7678d0665bb5cdf295d7aaaaa3e50eb2e44b8720e55097cc675af4dc8ec45acf9da39feb3eae1405d5

doc/devkit.core/Devkit_core/Parallel/Forks/index.html

Module Parallel.ForksSource

Forked workers

Parameters

module T : WorkerT

Signature

Sourcetype task = T.task
Sourcetype result = T.result
Sourcetype t
Sourceval create : (task -> result) -> int -> t

create f n starts n parallel workers waiting for tasks

Sourceval perform : t -> ?autoexit:bool -> task Enum.t -> (result -> unit) -> unit

perform workers tasks f distributes tasks to all workers in parallel, collecting results with f and returns when all tasks are finished

Sourceval stop : ?wait:int -> t -> unit

stop ?wait workers kills worker processes with SIGTERM is wait is specified it will wait for at most wait seconds before killing with SIGKILL, otherwise it will wait indefinitely

  • parameter autoexit

    determines whether workers will exit once there are no more tasks, it means perform shouldn't be called again for this instance

OCaml

Innovation. Community. Security.