public class TaskScheduler {
private Queue<Message> messageQueue;
public TaskScheduler() {
}
public void scheduleTask(Task task, String executionNode) {
Message message = new Message(task, executionNode);
}
}
python
def execute_task(message):
task = message.getTask()
result = ...
message.setResult(result)
return message
def main():
while True:
messages = messageQueue.getMessages()
for message in messages:
resultMessage = execute_task(message)
messageQueue.addResultMessage(resultMessage)
if __name__ == '__main__':
main()
