【问题标题】:Elixir: what's the point of Async HTTP?Elixir:异步 HTTP 的意义何在?
【发布时间】:2014-05-30 23:55:47
【问题描述】:

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

在 Elixir 中,每个请求都在一个轻量级进程(actor?)中处理,并且运行时可以在单个 OS 线程上多路复用数千个 actor。如果一个actor阻塞,运行时会交换另一个actor来使用cpu。由于参与者可以在不阻塞线程的情况下阻塞,所以我看不到 Elixir 中异步函数的意义。然而,我在 HTTPotion 文档中发现了这一点:

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

这里的异步函数有什么意义?

【问题讨论】:

  • 我只是在这里猜测,但我认为异步 API 的好处是可以逐步处理较长的响应块。您不必等待整个响应的到来,而是可以在每个块消息到达时对其进行操作。

标签: http asynchronous actor elixir


【解决方案1】:

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

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

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

希望这会有所帮助。关键是,参与者可以在不阻塞操作系统级线程的情况下阻塞,但有时您希望给定消息具有优先权,在这种情况下,从邮箱中选择性接收具有重要价值。例如,想象一个可能的消息相当于“shucks,因为这个值,我知道我根本不关心这个 http 响应”。然后,您可以关闭进程,而不会浪费 CPU 处理已在邮箱中排队的(较早接收的、CPU 密集型的)消息。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2023-03-19
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多