长生不老药如何保持蓄能器

Question

我在试着理解长生不老药流。

首先，我有一个列表，它用2迭代一个范围和倍数。

iex(5)>   stream = 1..3 |>
...(5)>   Enum.map(&IO.inspect(&1)) |>
...(5)>   Enum.map(&(&1 * 2)) |>
...(5)>   Enum.map(&IO.inspect(&1)) |>
...(5)>   Enum.reduce(4, &+/2)
1
2
3
2
4
6
16

这里一切都很清楚，每个枚举都返回一个列表，以便进一步处理该列表。它对列表中的每个元素迭代四次。

让我们用流构建它：

iex(4)>   stream = 1..3 |>
...(4)>   Stream.map(&IO.inspect(&1)) |>
...(4)>   Stream.map(&(&1 * 2)) |>
...(4)>   Stream.map(&IO.inspect(&1)) |>
...(4)>   Enum.reduce(4, &+/2)
1
2
2
4
3
6
16

在这里，它只对范围内的每个数字进行一次迭代，而不像上面使用枚举的例子那样。我不明白的是，当Enum.reduce的累加器只迭代一次时，它是如何保持值并由它们自己进行递归调用的？

当我迭代枚举时，如下所示：

iex(25)> f = fn(x, y) ->
...(25)> IO.puts(y)
...(25)> x + y
...(25)> end
#Function<12.54118792/2 in :erl_eval.expr/5>
iex(26)> iter = 1..5 |> Enum.reduce(4, f)
4
5
7
10
14
19

然后，我可以想象enum.reduce如何将累加器传递给下一个递归调用。

但是，如果流只执行一次迭代，那么流如何传递下一个递归调用的累加器？

Answer 1

不知道你错过了什么/问什么，但让我来解释一下。首先，您必须知道流是如何工作的，并且是用Elixir表示的: streams只是在可枚举的情况下操作的一组函数。当您组合流(例如，1..3 |> Stream.map(...) |> Stream.map(...))时，您没有对流执行任何“具体”操作，您只是将函数添加到将用于处理初始可枚举函数的列表中。当使用流调用Enum.reduce/3时，即开始迭代可枚举(每次一个元素)。

也可以通过检查Enum.reduce/3的进度来更好地理解您的示例：

iex> printer1 = fn el -> IO.puts "1st iteration, el: #{inspect el}"; el end
iex> printer2 = fn el -> IO.puts "2nd iteration, el: #{inspect el}"; el end
iex> reducer = fn el, acc ->
...>   IO.puts "reducing, el: #{inspect el}, acc: #{inspect acc}\n"
...>   el + acc
...> end
iex> 1..3 |> Stream.map(printer1) |> Stream.map(&(&1 + 10)) |> Stream.map(printer2) |> Enum.reduce(0, reducer)
1st iteration, el: 1
2nd iteration, el: 11
reducing, el: 11, acc: 0

1st iteration, el: 2
2nd iteration, el: 12
reducing, el: 12, acc: 11

1st iteration, el: 3
2nd iteration, el: 13
reducing, el: 13, acc: 23

36

正如您所看到的，几乎没有什么神奇的事情发生:当我们调用Enum.reduce/3时，流开始展开，我们遍历每个元素，映射这三个函数，并调用它和累加器上的reducer。

它可以帮助您研究Enumerable协议的文档，因为该协议用于将元素从流中提取出来(通常一次一个)。当您链接Enum.map/2操作时(如您在第一个示例中所做的那样)，Enum.reduce/3将接收一个列表作为其第一个参数，因此将使用列表的Enumerable协议:它的实现只是在列表上迭代，并将列表的元素“生成”给Enumerable.reduce，每次一个。当您链接Stream.map/2操作时，Enum.reduce/3将接收流，因此将使用流的Enumerable协议:它的实现从原始枚举(1..3)中取出每个元素，应用流操作(在本例中为Stream.map/2链)，并每次生成它们的结果。

希望我已经为你说得更清楚了，如果你还有疑问的话，请问一下:)。