Scala中的Java生产者和消费者模型

Question

我熟悉Java生产者和消费者模型。我有一个为另一个进程生成地图的过程来分析。我之前使用生产者和消费者模型在java中实现了这个模型。我也在Scala上做同样的尝试。本教程讨论的是参与者，即完成此过程的消息传递框架。但有什么很好的例子可以解释这些问题吗？在Scala中可以像在java中一样控制线程数吗？

Answer 1

下面的代码使用Akka实现生产者/消费者模型，Akka是面向参与者的Scala框架。

https://github.com/paulbutcher/AkkaProducerConsumerBenchmarks/tree/master/src

这是来自以下网页：

http://paulbutcher.com/2013/01/22/benchmarking-producerconsumer-in-akka/

还有阿克卡-骆驼，内置的生产者和消费者类别：

http://doc.akka.io/docs/akka/snapshot/scala/camel.html