Elixir中Task.async并行执行System.cmd遇Task.await超时错误排查

我之前批量安装Ruby版本的时候碰到过一模一样的问题！明明安装成功了，但Task就是挂着不退出，最后触发超时错误。折腾了半天终于找到几个核心问题点，帮你一一拆解：

最可能的原因：System.cmd未正确处理子进程IO流 #

rbenv install本质是封装Ruby编译过程的脚本，执行时容易出现以下IO相关问题：

• 某些编译脚本会默认等待标准输入（STDIN）的交互确认，而System.cmd默认会保持STDIN打开，导致子进程一直挂起等待输入
• 编译Ruby会产生大量输出，System.cmd默认把所有输出存在内存，缓冲溢出时会阻塞进程
• 子进程未正确关闭STDERR/STDOUT流，导致Elixir进程一直等待

解决办法：显式控制IO流 #

调用System.cmd时添加以下参数，强制处理IO流：

• stdin: :close：关闭子进程的标准输入，避免它等待交互
• stderr_to_stdout: true：合并错误输出到标准输出，统一处理
• into: file：把输出写入日志文件，避免内存缓冲溢出（还能方便后续排查问题）

代码片段示例：

# 创建日志文件
{:ok, log_file} = File.open("/tmp/rbenv_install_#{version}.log", [:write, :truncate])
# 执行安装命令并控制IO流
result = System.cmd("rbenv", ["install", version],
  stdin: :close,
  stderr_to_stdout: true,
  into: log_file
)
File.close(log_file)

次要可能原因：环境变量不匹配 #

Elixir进程的环境变量和终端shell的环境变量可能不一致，比如PATH中没有包含rbenv的shims目录，导致rbenv install执行时出现隐性异常（虽然最终能完成安装，但进程会挂起）。

解决办法：显式传递正确的环境变量 #

手动合并rbenv所需的PATH到环境变量中：

home = System.get_env("HOME")
# 构造包含rbenv的PATH
path = "#{home}/.rbenv/shims:#{home}/.rbenv/bin:#{System.get_env("PATH")}"
# 合并原有环境变量
env = Map.merge(System.get_env(), %{"PATH" => path})

# 使用新环境变量执行命令
System.cmd("rbenv", ["install", version], env: env, stdin: :close)

最后检查：Task.await的超时时间 #

编译Ruby版本可能需要十几分钟甚至更久，Task.await的默认超时时间（5秒）肯定不够，一定要设置足够长的超时，比如1小时：

# 3600_000毫秒 = 1小时
Task.await(task, 3600_000)

完整可运行代码 #

defmodule RubyBatchInstaller do
  def install(versions) do
    versions
    |> Enum.map(&spawn_install_task/1)
    |> Enum.map(&Task.await(&1, 3600_000))
  end

  defp spawn_install_task(version) do
    Task.async(fn ->
      IO.puts("Starting install: Ruby #{version}")
      home = System.get_env("HOME")
      # 构造正确的环境变量
      env = Map.merge(System.get_env(), %{"PATH" => "#{home}/.rbenv/shims:#{home}/.rbenv/bin:#{System.get_env("PATH")}"})
      
      # 创建日志文件并执行安装
      {:ok, log_file} = File.open("/tmp/rbenv_#{version}_install.log", [:write, :truncate])
      {_output, exit_status} = System.cmd("rbenv", ["install", version],
        env: env,
        stdin: :close,
        stderr_to_stdout: true,
        into: log_file
      )
      File.close(log_file)

      # 输出安装状态
      status = if exit_status == 0, do: :success, else: :failed
      IO.puts("Finished install: Ruby #{version} - #{status}")
      {version, status}
    end)
  end
end

# 使用示例
RubyBatchInstaller.install(["2.7.8", "3.0.6", "3.2.2"])

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