get_best_pid

Scheduler.ex

defmodule Scheduler do
  def get_best_pid(group) do
    mems = :pg2.get_members(group) |> 
    	    Enum.map(fn(pid) -> 
	          [message_queue_len: msgs, stack_size: ss] = :rpc.pinfo(pid, [:message_queue_len, :stack_size]) 
	    	  {pid, msgs, ss} 
	    end) |>
	    Enum.sort(fn ({_, q1, s1}, {_, q2, s2}) -> q1 < q2 or (q1 == q2 and s1 < s2) end)
    case mems do
      [{pid, _, _} | _] -> pid
      [] -> {:error, :empty_process_group}
    end
  end
end