package fuseau-lwt

  1. Overview
  2. Docs
Lwt backend for Fuseau

Install

Dune Dependency

Authors

Maintainers

Sources

fuseau-0.1.tbz
sha256=8a9339d239aa371d0c4aceb23d7601a1b7da8f42d84542cee30669cc95addb6a
sha512=fa656c7311371344f0c6ebf08c666afc33296558ccc678ed87baf2f9ba54035cd4c5caca4257212416296fcdbdfc1687c46cc2ebea3548c792ea72602b85b832

Description

Tags

fuseau lwt

Published: 27 Feb 2024

README

Fuseau

This is an experimental concurrency/IO library for OCaml 5. Currently the only backend is a naive one using Unix.select but I plan to add more robust ones.

A basic example that spins 4 concurrent loops in direct style:

# let spf = Printf.sprintf
val spf : ('a, unit, string) format -> 'a = <fun>

# let main () =
  print_endline "entering main";

  let computations =
    Array.init 4 (fun j ->
        Fuseau.spawn @@ fun () ->
        print_endline @@ spf "spawn fiber %d" j;
        for i = 1 to 3 do
          (* this suspends the fiber for 500ms *)
          Fuseau.sleep_s 0.5;
          print_endline @@ spf "iter %d (fiber %d)" i j
        done)
  in

  (* wait for the loops to end *)
  Array.iter Fuseau.await computations;
  print_endline "done"
val main : unit -> unit = <fun>

# let () = Fuseau_unix.main main
entering main
spawn fiber 0
spawn fiber 1
spawn fiber 2
spawn fiber 3
iter 1 (fiber 0)
iter 1 (fiber 1)
iter 1 (fiber 2)
iter 1 (fiber 3)
iter 2 (fiber 0)
iter 2 (fiber 1)
iter 2 (fiber 2)
iter 2 (fiber 3)
iter 3 (fiber 0)
iter 3 (fiber 1)
iter 3 (fiber 2)
iter 3 (fiber 3)
done

License

MIT licensed.

Name

Fuseau ("fuh-zo") is french for a spindle. It's vaguely related to fibers :-)

Dependencies (5)

  1. fuseau = version
  2. base-unix
  3. lwt
  4. trace >= "0.6"
  5. dune >= "3.0"

Dev Dependencies (2)

  1. odoc with-doc
  2. trace-tef with-test

Used by

None

Conflicts

None

OCaml

Innovation. Community. Security.