double taskCommunicateSize = Double.valueOf(args[2]).doubleValue();
BasicTask[] todo = new BasicTask[numberOfTasks];
- String taskName = null;
-
for (int i = 0; i < numberOfTasks; i++) {
todo[i] = new BasicTask("Task_" + i, taskComputeSize, taskCommunicateSize);
}
Msg.info("All tasks have been dispatched. Let's tell everybody the computation is over.");
for (int i = 0; i < slaveCount; i++) {
- BasicTask task = new BasicTask("finalize", 0, 0);
- task.setData(221297);
- channel.put(task,slaves[i]);
+ channel.put(new FinalizeTask(),slaves[i]);
}
Msg.info("Goodbye now!");