package async_parallel

You can search for identifiers within the package.

in-package search v0.2.0

async_parallel
- Async_parallel_deprecated
  - Channel
  - Hub
    
    Client_id
    
    Hash_queue
    
    Key
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Map
    
    Key
    
    Provide_bin_io
    
    Key
    
    Provide_hash
    
    Key
    
    Provide_of_sexp
    
    Key
    
    Tree
    
    Provide_of_sexp
    
    K
    
    Replace_polymorphic_compare
    
    Set
    
    Elt
    
    Provide_bin_io
    
    Elt
    
    Provide_hash
    
    Elt
    
    Provide_of_sexp
    
    Elt
    
    Tree
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
  - Import
    
    Cluster
    
    Socket_file
  - Intf
  - Master_process
  - Std
  - Token
  - Worker_process
    
    From_worker
    
    To_worker

Legend:
Library
Module
Module type
Parameter
Class
Class type

This interface is not intended to be used directly by users!

The master process forks a worker process for each task that Parallel is asked to do. After forking, in the worker process, the master calls Worker_process.run, which:

1. accepts a single connection from its control_socket. 2. reads a single marshaled To_worker.Run f message over the connection. 3. creates a hub with control_socket and supplies it to f. 4. when f returns, writes a single From_worker message with the result over the control_socket connection. 5. exits.

module To_worker : sig ... end

module From_worker : sig ... end

val run : 
  control_socket:([ `Passive ], Async.Socket.Address.Inet.t) Async.Socket.t ->
  Core.never_returns