View Source Queue (fnord v0.5.8)
A module that implements a process pool using a GenServer.
Summary
Functions
Returns a specification to start this module under a supervisor.
Returns a list of jobs currently being processed.
Callback implementation for GenServer.init/1.
Returns true if the queue is idle (no waiters, nothing in the queue), false otherwise.
Waits until the queue is empty and all workers have exited.
Queues an Enum of jobs, executes them, and returns the results in order.
Adds a job to the queue and returns a Task.
Shuts down the queue, preventing new jobs from being added.
Starts the Queue with the given callback function and maximum number of workers. Returns {:ok, pid}
Functions
Returns a specification to start this module under a supervisor.
See Supervisor.
Returns a list of jobs currently being processed.
Callback implementation for GenServer.init/1.
Returns true if the queue is idle (no waiters, nothing in the queue), false otherwise.
Waits until the queue is empty and all workers have exited.
Queues an Enum of jobs, executes them, and returns the results in order.
Adds a job to the queue and returns a Task.
Shuts down the queue, preventing new jobs from being added.
Starts the Queue with the given callback function and maximum number of workers. Returns {:ok, pid}