混合任务产生一个进程什么都不做

Question

我创建了一个生成进程的混合任务。 它使用Flow，从流中读取并写入consumer 中定义的文件。

归根结底，它只是产生了一些进程。

如果我通过 iex 运行它，只要我让 shell 运行，它就可以正常工作。

但是，如果我从命令行将它作为混合任务启动，则没有任何反应，你如何让进程保持打开状态？

  use Flow

  def run([stream]) do
    specs = [{{ProdCon,[]},[]}]
    consumer = [{{Consumer,[]},[]}]

    stream
    |> Flow.from_enumerable()
    |> Flow.through_specs(specs)
    |> Flow.into_specs(consumer)
  end

Answer 1

生成一个 Task 来完成这项工作并等待它以 Task.yield/2 完成：

use Flow

def run([stream]) do
  task = Task.async(fn ->

    specs = [{{ProdCon,[]},[]}]
    consumer = [{{Consumer,[]},[]}]

    stream
    |> Flow.from_enumerable()
    |> Flow.through_specs(specs)
    |> Flow.into_specs(consumer)

  end)

  case Task.yield(task, 3_600) do # wait 1 hour
    {:ok, result} -> result
    nil -> IO.puts("Failed to get a result :(")
  end
end