Elixir:Async HTTP有什么意义？

Question

我习惯于在线程上运行请求处理程序的语言,因此所有I/O函数都有一个异步版本来防止阻塞线程.

在Elixir中,每个请求都在一个轻量级进程(actor？)中处理,运行时可以在一个OS线程上复用数千个actor.如果actor阻塞,则运行时交换另一个actor以使用cpu.因为,一个actor可以在不阻塞线程的情况下阻塞,但我没有看到Elixir中的异步函数.然而,我在HTTPotion文档中遇到了这个问题:

iex> HTTPotion.get "http://floatboth.com", [], [stream_to: self]
%HTTPotion.AsyncResponse{id: {1372,8757,656584}}

这里的异步功能有什么意义？

Answer 1

根据 HTTPotion 的 README，使用stream_to 将导致将消息发送到为 http 响应的每个块提供的 Pid。您可以使用接收块来接受这些并相应地处理它们。

一般来说，说“在 Elixir 中，每个请求都被处理......”是没有意义的，因为请求意味着非常具体的事情。假设这与网络应用程序和入站请求有关。

在 Elixir 中，每个进程都是按顺序执行的一段代码。当该代码块完成时，进程就会终止。 HTTPotion 中异步响应的一种用途是选择性接收，您希望尽可能快地处理内容，但匹配特定模式的消息可能会优先。选择性接收是 Erlang 处理并发的方式相对于 Go 处理并发的方式（CSP）的优势之一。

希望这有帮助。关键是，参与者可以在不阻塞操作系统级线程的情况下进行阻塞，但有时您希望给定的消息具有优先级，在这种情况下，从邮箱中选择性接收具有很大的价值。例如，假设其中一条可能的消息相当于“shucks，因为这个值，我知道我根本不关心这个 http 响应”。然后，您可以关闭该进程，而不是浪费 CPU 来处理邮箱中排队的（较早收到的、CPU 密集型的）消息。