package async

You can search for identifiers within the package.

in-package search v0.2.0

Monadic concurrency library

Install

sha256=74f2b7b01ce3b92289cc7a68cd3ae53885c763cedd320d27949d585e5c13dc64

md5=9f80cfb72e3defcc9fca50f67e23e93c

type t

Flock has async analogues of functions in Lock_file_blocking.Flock; see there for documentation.

Additionally, here we:

val lock_exn : 
  lock_path:string ->
  [ `Somebody_else_took_it | `We_took_it of t ] Async.Deferred.t

val lock : 
  lock_path:string ->
  [ `Somebody_else_took_it | `We_took_it of t ] Async.Deferred.Or_error.t

val unlock_exn : t -> unit Async.Deferred.t

val unlock : t -> unit Async.Deferred.Or_error.t

val wait_for_lock_exn : 
  ?abort:unit Async.Deferred.t ->
  lock_path:string ->
  unit ->
  t Async.Deferred.t

wait_for_lock_exn ?abort ~lock_path () Wait for the lock, giving up once abort becomes determined

val wait_for_lock : 
  ?abort:unit Async.Deferred.t ->
  lock_path:string ->
  unit ->
  t Async.Deferred.Or_error.t

See wait_for_lock_exn