1

考虑以下代码片段：

一种）

IO.puts "test1"
task = Task.async fn ->
  Foo.Bar.send_file_for_processing(file_url)
end
IO.puts "test2"
content = Task.await(task)
IO.puts "test4"

b)

IO.puts "test1"
content = Foo.Bar.send_file_for_processing(file_url)
IO.puts "test2"

在 Foo.Bar 模块中：

def send_file_for_processing(file_url) do
  json = file_url |> encoded_file |> request_json
  IO.puts "test3"
  request = HTTPoison.post(
    @processing_endpoint,
    json,
    @headers,
    params: %{"key": @api_key}, connect_timeout: 100000, recv_timeout: 100000, timeout: 100000
  )
  IO.puts "test5"

  (...)
end

当我使用代码片段 a) 时，永远不会到达“test5”，就好像程序会在 HTTPoison POST 请求期间挂起一样。它只是永远不会结束。同时，使用代码段 b)，HTTPoison POST 请求正常完成，没有任何延迟。

老实说，调试这让我浪费了一些时间，我仍然不明白代码段 a) 的问题。我是否滥用了任务模块？我检查了文档，找不到任何可以向我解释这个问题的东西。

编辑：片段 a) 的输出

test1
test2
test3
4

1 回答 1

2

我可以看到您的 HTTP 请求的超时值很高。该任务的默认超时值为5_000 ms，因此该任务很可能在请求完成之前超时。随后任务被终止，您永远看不到输出。该Task.await/2函数接受超时作为第二个参数。

无论如何，您应该会看到任务超时错误。也许你忽略了一些输出？

于 2016-11-06T14:28:45.327 回答