A pool implementation for the current concurrency library.
val create :
?max_size:int ->
?max_idle_size:int ->
?check:('a -> (bool -> unit) -> unit) ->
?validate:('a -> bool System.future) ->
(unit -> ('a, 'e) result System.future) ->
('a -> unit System.future) ->
('a, 'e) tInternal: create alloc free is a pool of resources allocated by alloc and freed by free. This is primarily intended for implementing the connect_pool functions.
val size : ('a, 'e) t -> intsize pool is the current number of open resources in pool.
val use :
?priority:float ->
('a -> ('b, 'e) result System.future) ->
('a, 'e) t ->
('b, 'e) result System.futureuse f pool calls f on a resource drawn from pool, handing back the resource to the pool when f exits.
val drain : ('a, 'e) t -> unit System.futuredrain pool closes all resources in pool. The pool is still usable, as new resources will be created on demand.