Packages

process_hub

0.2.5-alpha
0.6.0 0.5.0-beta 0.4.1-beta 0.4.0-beta 0.3.3-alpha 0.3.2-alpha 0.3.1-alpha 0.3.0-alpha 0.2.10-alpha 0.2.9-alpha 0.2.8-alpha 0.2.7-alpha 0.2.6-alpha 0.2.5-alpha 0.2.4-alpha 0.2.3-alpha 0.2.2-alpha 0.2.1-alpha 0.2.0-alpha 0.1.4-alpha 0.1.3-alpha 0.1.2-alpha 0.1.1-alpha 0.1.0-alpha

Distributed processes manager and global process registry

HexDocs

Current section

Files

Jump to
Readme
24 Versions
3 Dependencies
Dependants
Files
Activity
process_hub lib process_hub worker_queue.ex
Raw

lib/process_hub/worker_queue.ex 

defmodule ProcessHub.WorkerQueue do

  use GenServer



  def start_link(name) do

    GenServer.start_link(__MODULE__, nil, name: name)

  end



  def init(_) do

    {:ok, nil}

  end



  def handle_cast({:handle_work, func}, state) do

    func.()



    {:noreply, state}

  end



  def handle_call({:handle_work, func}, _from, state) do

    {:reply, func.(), state}

  end

end