function - 如何从 Elixir GenServer 处理程序中调用其他函数？

Question

我有一个为单个项目实现功能的 GenServer，例如:

def handle_call({:sync, id}, _from, state) do
    ## update data
    {:reply, data, sync}
end

现在我想为多个 id 处理这个功能，例如:

def handle_call({:sync_all, ids}, _from, state) do
    ## call sync for each id
    data = Enum.map(ids, fn(id) ->
        GenServer.call(self(), {:sync, id})
    end)
    ## Further reduce down data to stats
    {:reply, data, sync}
end

然而，这并不能告诉我进程试图调用自己。

我认为这一定是由于 call 的阻塞性质造成的。但是，如果我在 sync_all 版本中使用 cast，也会发生同样的情况。

所以我的问题是:如何从 handle_call 或 handle_cast 函数中调用其他 GenServer 任务？

Answer 1

在这种情况下，您通常会做的是将通用逻辑提取到一个单独的函数中:

def handle_call({:sync, id}, _from, state) do
  {data, state} = do_sync(id, state)
  {:reply, data, state}
end

def handle_call({:sync_all, ids}, _from, state) do
  {data, state} = Enum.map_reduce(ids, state, &do_sync/2)
  {:reply, data, state}
end

defp do_sync(id, state) do
  # do something
  {data, new_state}
end