package eio

You can search for identifiers within the package.

in-package search v0.2.0

Effect-based direct-style IO API for OCaml

Install

dune-project

Dependency

github.com Readme Changelog ISC License Edit opam file Versions (22)

Authors

Maintainers

A

anil@recoil.org

Sources

eio-1.6.tbz

sha256=c1f04986b401094176494863dde1ca9b292b59fdc679a9d7023e558d80fb5b15

sha512=92ed8cf20300b8a4e0141bdbc373c0803c5a24530cb65852637d905fff4a5b956a8859a00a424034ff78c1112da9b0391194bcd558326168bdebd1ce683a8890

doc/eio/Eio/Pool/index.html

Module `Eio.Pool`Source

A pool of resources.

This is useful to manage a collection of resources where creating new ones is expensive and so you want to reuse them where possible.

Example:

  let buffer_pool = Eio.Pool.create 10 (fun () -> Bytes.create 1024) in
  Eio.Pool.use buffer_pool (fun buf -> ...)

Note: If you just need to limit how many resources are in use, it is simpler to use Eio.Semaphore instead.

Sourcetype 'a t

Source

val create : 
  ?validate:('a -> bool) ->
  ?dispose:('a -> unit) ->
  int ->
  (unit -> 'a) ->
  'a t

create n alloc is a fresh pool which allows up to n resources to be live at a time. It uses alloc to create new resources as needed. If alloc raises an exception then that use fails, but future calls to use will retry.

The alloc function is called in the context of the fiber trying to use the pool.

You should take care about handling cancellation in alloc, since resources are typically attached to a switch with the lifetime of the pool, meaning that if alloc fails then they won't be freed automatically until the pool itself is finished.

parameter validate
If given, this is used to check each resource before using it. If it returns false, the pool removes it with dispose and then allocates a fresh resource.

parameter dispose
Used to free resources rejected by validate. If it raises, the exception is passed on to the user, but resource is still considered to have been disposed.

Sourceval use : ?never_block:bool -> 'a t -> ('a -> 'b) -> 'b

use t fn waits for some resource x to be available and then runs f x. Afterwards (on success or error), x is returned to the pool.

parameter never_block
If true and the pool has reached maximum capacity, then a fresh resource is created to ensure that this use call does not wait for a resource to become available. This resource is immediately disposed after f x returns.