我是 Scala 的新手。我对 Scala 的未来概念有一个一般性疑问。
假设我有一个元素列表,并且列表中存在每个元素,我必须调用一个进行一些处理的方法。
我们可以使用未来的方法并且可以并行进行处理,但我的问题是我们如何控制并行/后台运行的并发处理任务。
例如,我应该将并行运行任务限制保持为 10。因此,在 Max 时,我的未来应该生成对列表中 10 个元素的处理,并等待任何生成的进程完成。一旦空闲插槽可用,它应该为剩余元素生成进程,直到达到最大值。
我在谷歌中搜索但找不到它。在 Unix 中,可以通过在后台运行进程并使用 ps 命令手动检查计数来完成相同的操作。由于不太了解 Scala。请帮助我。
提前致谢。