Elixir中如何等待所有spawn进程完成并正确收集计算结果？

你提到的跟踪已接收消息数量，达到目标时停止循环的思路完全正确，这也是Elixir中处理固定数量子进程任务结果收集的标准做法。下面是修改后的可运行代码：

defmodule Counter do
  # 调整loop参数，增加已接收数量和目标数量
  def loop(items \\ [], received_count \\ 0, target_count) do
    receive do
      {:append, item} ->
        new_received = received_count + 1
        new_items = [item | items]
        
        # 检查是否已收集所有结果
        if new_received == target_count do
          # 可选：如果需要正序结果，这里反转列表
          Enum.reverse(new_items)
        else
          loop(new_items, new_received, target_count)
        end
    end
  end

  def push(from_pid, item) do
    send(from_pid, {:append, :math.pow(item, 2)})
  end

  def run() do
    target = 10
    # 创建子进程
    for item <- 1..target do
      spawn(Counter, :push, [self(), item])
    end

    # 启动循环并传入目标数量
    loop([], 0, target)
  end
end

# 运行并打印结果
IO.inspect(Counter.run())

关键修改说明： #

• 增加计数跟踪：loop/3函数新增received_count（已接收消息数）和target_count（需要收集的总结果数）两个参数，每次收到子进程的结果后递增计数。
• 终止条件判断：当received_count等于target_count时，直接返回收集到的结果（可选反转列表以保持原数字顺序），不再递归调用loop，自然终止消息监听。
• 明确目标数量：在run/0中先定义target变量，避免硬编码，同时确保子进程数量和目标数量一致。

为什么这是正确的实现？ #

因为你明确知道需要执行的任务数量（10个），每个子进程只会发送一条结果消息，通过计数可以精准判断所有任务是否完成，这种方式逻辑简单、可靠，没有额外的进程同步开销，完全适配你的场景。

内容的提问来源于stack exchange，提问作者Karolis