正确等待进程完成

Question

目前我有这样的事情：

ref = Process.monitor(worker)

receive do
  {:DOWN, ^ref, :process, ^worker, :normal} ->
    IO.puts("Normal exit from #{inspect(worker)}")

  {:DOWN, ^ref, :process, ^worker, msg} ->
    IO.puts("Received :DOWN from #{inspect(worker)}")
end

那个工人有一个 start_link 它将数据流发送到消费者，所有这一切都发生在一个混合任务中，所以如果我不添加接收，一旦混合死亡，它也会杀死子进程，同样就像我从 iex -S mix shell 运行它一样。

flow
... some producer consumer in the middle
|> Flow.into_specs(consumer)

问题是，当流为空时（是一个有限流），worker 似乎没有死，接收不会被触发，还有其他方法可以实现吗？

编辑：

用我什至不需要receive do的虚拟进程进行测试

defmodule Mix.Tasks.Stuff do


  def run([]) do
    {:ok, worker} = Worker.start_link([])
  end
end

defmodule Worker do

  def start_link([]) do
    Enum.map([1, 2, 3, 4, 5, 6, 7, 8, 9, 10], fn number ->
      IO.puts "COUNTING"
      Process.sleep(1000)
      IO.puts "-----------"
    end)
  end
end

但是当工作人员启动 Flow 时，如果我不等待 receive do，它会在我执行任务时立即死亡，所以也许这就是问题所在。

Answer 1

根据Process.monitor/1上的文档：

如果在调用Process.monitor/1 时进程已经死亡，则立即传递:DOWN 消息。

也就是说，当Flow 为空时，receive do 为:DOWN 消息设置处理程序在发送之后。为了处理这种情况，应该在开始监视进程之前交换调用并准备消息处理程序。

receive do
  {:DOWN, ref, :process, ^worker, msg} ->
    case [retrieve_ref(), msg] do
      [^ref, :normal] ->
        IO.puts("Normal exit from #{inspect(worker)}")
      [^ref, msg] ->
        IO.puts("Received :DOWN from #{inspect(worker)}")
    end
end

ref = Process.monitor(worker)
store_ref_somewhere_ets_or_agent_or_whatever(ref)

我认为store_ref_somewhere_ets_or_agent_or_whatever/1 和各自的retrieve_ref/0 很容易实现。