【发布时间】:2016-07-28 20:38:51
【问题描述】:
想象这样一种情况,我们有一个调度系统(1 个主机),例如,6 台计算机(工作人员)打算执行来自调度系统的指令。
在典型情况下,我们可以使用task = new Task(name, computingSize, communicationSize)。如果我们希望 worker1 开始处理任务,我们通常使用task.send(mailboxOfWorker1)。
但是当所有数据都存储在worker1主机上的情况下呢?我们如何从调度系统(Master)向worker1发送指令以开始处理一些task(name, compSize, commSize)(当任务的数据存储在worker1上时)。或者例如这种情况,我们如何从调度系统向worker1发送指令——首先从worker2下载数据,然后(在从worker2检索数据后)开始执行它们(在worker1上)?
【问题讨论】:
-
所以你想把一个工人的任务交给下一个工人?例如,您是否检查了 token_ring 示例?
-
是的,我希望Master向worker1发送任务,告诉他从worker2下载数据,然后执行。
标签: java scheduled-tasks scheduling job-scheduling simgrid