Comment Comment by talex5 Instead of Stdlib.Queue you can use Eio.Stream, which is thread-safe (and will take care of waking sleeping threads when data becomes available).The README shows an example of a pool of workers pulling jobs from an Eio.Stream:https://github.com/ocaml-multicore/eio#example-a-worker-poolWe're still exploring what APIs to provide for this kind of thing, and in particular how to unify domainslib and eio. parent talex5 4 years ago
The README shows an example of a pool of workers pulling jobs from an Eio.Stream:
https://github.com/ocaml-multicore/eio#example-a-worker-pool
We're still exploring what APIs to provide for this kind of thing, and in particular how to unify domainslib and eio.