package parany

You can search for identifiers within the package.

in-package search v0.2.0

parany
- Parany
  - Parmap

Legend:
Library
Module
Module type
Parameter
Class
Class type

exception End_of_input

The demux function must throw Parany.End_of_input once it is done.

val run : 
  ?preserve:bool ->
  ?csize:int ->
  int ->
  demux:(unit -> 'a) ->
  work:('a -> 'b) ->
  mux:('b -> unit) ->
  unit

run ~csize:10 16 ~demux:f ~work:g ~mux:h will run in parallel on 16 cores the g function. Inputs to function g are produced by function f and grouped by 10 (the chunk size csize). If not provided, csize defaults to one. The performance-optimal csize depends on your computer, the functions you are using and the granularity of your computation. Elements which are fast to process may benefit from a csize greater than one. The demux function f must throw Parany.End_of_input once it is done. Outputs of function g are consumed by function h. Functions f and g are run by different unix processes. Function g is run by several processes at the same time (16 in this example). Only function mux is run by the same process that called Parany.run. ~preserve is an optional parameter which defaults to false. If set to true, results will be accumulated by h in the same order that function f emitted them. However, for parallel performance reasons, the jobs are still potentially computed by g out of order.

module Parmap : sig ... end

Wrapper module for near-compatibility with Parmap