我熟悉 Java 生产者和消费者模型。我有一个生成 map 供另一个进程分析的进程。我之前使用生产者和消费者模型在 Java 中实现了这个模型。我正在尝试在 Scala 中做同样的事情。教程讨论了执行此过程的参与者、消息传递框架。但是有什么好的例子可以解释它们吗？ Scala可以像java一样控制线程数吗？
最佳答案
下面是使用 Akka(Actor 的 Scala 框架)实现生产者/消费者模型的代码。
https://github.com/paulbutcher/AkkaProducerConsumerBenchmarks/tree/master/src
这是来自以下网页:
http://paulbutcher.com/2013/01/22/benchmarking-producerconsumer-in-akka/
还有 akka-camel，内置了 Producer 和 Consumer 类:
关于Scala 中的 Java 生产者和消费者模型，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/21014448/