问使用Java (流)的生产者消费者[线程/处理]

EN

我正在做一个项目，本质上是一个很长的生产者/消费者链。这意味着第一个进程从用户获取数据(巨大的csv文件)，逐行处理数据，传递到另一个进程/线程，该进程/线程消耗这些数据，进程然后再传递到另一个进程，以此类推。

这条链大约有8-10个单元长，每个单位都是消费者，然后是生产者。

我已经考虑过使用AWS lambdas来做这件事。我也可以使用Java流。我在AWS中看到的优点是，您可以在每个节点上设置单独的节流限制。

因此，如果您的节点的任务是更新dynamodb记录，我们可以节流此节点以匹配dynamodb的写入单元等等。

我发现使用lambda的另一个优势是，我不必编写代码来管理多处理(或多线程)，而且我的数据处理将不依赖于我选择的硬件--我也可以通过选择一个低级硬件来节省成本，它的唯一工作将是充当第一个生产者，但我仍然会为aws lambda付费。

1. 如果我使用并以相同的方式使用Java流是否类似于使用AWS？我可以在Java中使用节流吗？
2. 如果我使用Java流，是否有一种简单的方法来管理多处理(线程)。
3. 除了节流和管理池之外，使用lambda还有其他好处吗？有什么缺点吗？
4. 除了上述两项外，还有其他选择吗？
5. 如果我希望对链中的某些节点使用多个使用者，该怎么办？例如，消费者使用数据，处理数据并将其传递给链中的下一个数据，但我们也必须记录数据或将其存储在db中。