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



我熟悉Java生产者和消费者模型。我有一个过程,可以为另一个过程生成地图进行分析。我之前在java中使用生产者和消费者模型执行了这个模型。我正在尝试在 Scala 中做同样的事情。 教程讨论了执行此过程的参与者,消息传递框架。但是有什么好的例子可以解释它们吗?线程的数量可以在 Scala 中像在 Java 中一样控制吗?

这是使用 Akka(Scala 的参与者框架)实现生产者/消费者模型的代码。

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

这是来自以下网页:

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

还有 akka-camel,具有内置的生产者和消费者类:

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

最新更新