Concur

Concurrency and streams utilities.

This library embeds multiple modules for dealing with concurrency and Elixir streams. Including:

• Semaphores

Installation

If available in Hex, the package can be installed by adding concur to your list of dependencies in mix.exs:

def deps do
  [
    {:concur, "~> 0.1.0"}
  ]
end

Usage

The Concur.Semaphore provides a full semaphores implementation for it to be used by either concurrent or synchronous code. It contains the two semaphore primitives: wait and signal. Here's an example:

alias Concur.Semaphore, as: Sem

sem = Sem.new(1)

# Process 1
Sem.wait() # => Proceeds to obtain the semaphore and continue executing

# Process 2
Sem.wait() # => Blocks until the semaphore is unblocked

# Process 1
Sem.signal() # => Unblocks semaphore. Process 2 continues executing

LICENSE

See LICENSE