如何解决Elixir中如何在进程间调度多个任务的调度
我正在尝试基于 google 的 MapReduce article 在 elixir 中实现一个通用的 Map Reduce 流程。我在进程间分配任务时遇到问题。
我有一个充当映射器或减速器的工作模块和一个用于协调的主模块。问题是 我想将输入数据的多个分区分派给一些工人(映射器)并注意工人的数量少于分区(任务),所以我必须将分区的一些子集分派给工人并等待工人完成他们的工作,然后为每个变空的工人(映射器)分配一个新任务,直到完成所有任务(分区)。映射阶段是这种情况,但减少阶段是相同的。
由于我是新手,我不知道如何在 elixir 中做到这一点。此外,我希望我的工人成为灵丹妙药,以便梁可以有效地管理他们。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。