Skip to content

rgrinberg/ebqueue

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

21 Commits
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Ebqueue - Simplest Blocking Unbounded Queue in Erlang

Usage

% create a queue
{ok, Q} = ebqueue:start_link().

% add some elements

ebqueue:in({xxx, 123}, Q).
ebqueue:in({yyy, 456}, Q).

% read from the queue
{ok, Element} = ebqueue:out(Q).

% read from queue with timeout
case ebqueue:out(Q, 1000) of
    timeout -> io:format("Timed out.");
    {ok, E} -> io:format("Got element ~p", [E])
end.

About

Tiny simple blocking queue in erlang

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published