小编ung*_*cky的帖子

Scala中如何控制未来的并发?

我是 Scala 的新手。我对 Scala 的未来概念有一个一般性疑问。

假设我有一个元素列表,并且列表中存在每个元素,我必须调用一个进行一些处理的方法。

我们可以使用未来的方法并且可以并行进行处理,但我的问题是我们如何控制并行/后台运行的并发处理任务。

例如,我应该将并行运行任务限制保持为 10。因此,在 Max 时,我的未来应该生成对列表中 10 个元素的处理,并等待任何生成的进程完成。一旦空闲插槽可用,它应该为剩余元素生成进程,直到达到最大值。

我在谷歌中搜索但找不到它。在 Unix 中,可以通过在后台运行进程并使用 ps 命令手动检查计数来完成相同的操作。由于不太了解 Scala。请帮助我。

提前致谢。

parallel-processing scala

0
推荐指数
1
解决办法
1196
查看次数

标签 统计

parallel-processing ×1

scala ×1