Akka流-将IO绑定流放到不同的分派程序上

Question

我的流有一个CPU绑定和IO绑定阶段的均匀混合（每个IO阶段后面都有一个CPU阶段）。我想要做的是将IO操作放在一个不同于流其余部分的分派程序上。

在一个传统的基于actor的Akka应用程序中，我可以将IO actor放在一个固定的线程池调度器上，它有很多线程，而将CPU绑定的actor放在一个fork join池上，它有少量的线程（一些是核数的倍数，理想情况下是1）。这将减少CPU绑定参与者在线程切换中浪费的时间，同时通过在IO上阻塞大量线程来提高吞吐量。

这样的认识对吗？若否，原因为何？如果是，那么我如何将我的IO绑定的阶段（流）与流的其余部分放在一个单独的分派器上呢？

我试过关闭自动保险丝，这确实有帮助。但它的吞吐量仍然比几乎等价的Akka同类产品要低得多。

Answer 1

默认情况下,流中的所有阶段都运行在同一个执行元上,您可以使用属性标记阶段应运行在单独的调度程序上,如下所示：

stage.withAttributes(ActorAttributes.dispatcher("dispatcher-name"))

这还将在该阶段周围引入异步边界，有效地在它自己的执行元中运行它。为了避免异步边界变得代价高昂，该阶段现在实际上将从上游一次发送16个元素的需求，因此您必须意识到这一点。

可以使用一个附加属性来调整缓冲区大小，在本例中，它的行为类似于融合的阶段，因为它一次请求一个元素，请注意，这可能会带来太多开销，这取决于用例。

stage.withAttributes(Attributes.inputBuffer(1, 1))

null