我熟悉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