Как мне смоделировать приоритет задач?

Question

Я пытаюсь смоделировать кучу задач, которые все вместе принадлежат одному и тому же универсальному проекту.
Задачи имеют продолжительность и приоритет (представлены списком задач, которые должны быть выполнены до текущей задачи).

Например:

      /--->A --->B\
Start ---->C------->End
      \--->D---->E/

Это означает, что задачи A, C и D могут выполняться одновременно, но задача B должна выполняться после задачи A, а задача E - после задачи D.

Я написал этот код:

#!/usr/bin/python2.7
# -*- coding: utf-8 -*-
import simpy


class Task(object):
    """ 
        Has an id i.e.: 'E',
        duration i.e.: 5
        a list with Task that precede the current
    """
    def __init__(self, idTask, duration, env, previousTasks=None):
        self.idTask = idTask
        self.duration = duration
        self.env = envs
        self.completed = env.event()
        self.action = env.process(self.run())
        if previousTasks is None:
            self.previousTasks = []
        else:
            self.previousTasks = previousTasks

    def run(self):
        while self.can_execute() and not self.completed.triggered:
            print "Starting task %s at time %s" % (self.idTask, self.env.now)
            yield self.env.timeout(self.duration)
            print "Completed task %s in time %s" % (self.idTask, self.env.now)
            self.completed.succeed(True)

    def can_execute(self):
        result = True
        for task in self.previousTasks:
            if not task.completed.triggered:
                result = False
                break
        return result

if __name__ == "__main__":
    env = simpy.Environment()
    taskA = Task('A', 4, env)
    taskB = Task('B', 5, env, [taskA])
    env.run(until=20)

Завершенный атрибут в объекте "Задача" предназначен для определения того, завершена или завершена текущая задача. (Я попытался сделать это с логическим значением без каких-либо других результатов.)

Задача B имеет задачу A в качестве прецедентной задачи. Это означает, что taskB должен запуститься до завершения taskA, но это вывод при запуске:

% python tasks.py
Starting task A at time 0
Completed task A at time 4
%

Я не понимаю, почему TaskB не может работать.

-------------------------------------------------- -------------------------

РЕШИТЬ

Я использовал метод start_delayed, доступный в модуле simpy.util от Simpy. В зависимости от того, есть ли у текущей задачи предыдущие задачи, "действие" каждой задачи является простым процессом или процессом с задержкой.
Задержка для каждой задачи вычисляется в add_precedences и эстимейлах_оценки, но необходима для суммирования продолжительности предыдущих задач с предыдущей задачей текущей.
Вот окончательный код:

#!/usr/bin/python2.7
# -*- coding: utf-8 -*-
import simpy
from simpy.util import start_delayed

delays = {}
completed = []


class Task(object):
    """ Has an id i.e.: 'E',
        duration i.e.: 5
        a list with Task that precede the current
    """
    def __init__(self, id, duration, env, previousTasks=None):
        self.id = id
        self.duration = duration
        self.env = env
        if previousTasks is None:
            self.previousTasks = []
        else:
            self.previousTasks = previousTasks
        self.action = None

    def run(self):
        while True:
            if delays[self.id] == self.env.now:
                print "Start task: %s at time: %s" % (self.id, self.env.now)
                yield self.env.timeout(self.duration)
                completed.append(self.id)
                print "Finish task: %s at time: %s" % (self.id, self.env.now)
            else:
                if self.id in completed:
                    self.env.exit()


def add_precedences(prevTask, durations):
    if len(prevTask) == 0:
        return 0
    else:
        durations.extend(map(lambda x: x.duration, prevTask))
        for prev in prevTask:
            add_precedences(prev.previousTasks, durations)
        return sum(durations)


def estimate_delays(tasks):
    result = {}
    for task in tasks:
        durations = []
        total = (add_precedences(task.previousTasks, durations))
        result.update({task.id: total})
    return result


def set_action(tasks):
    for task in tasks:
        if delays[task.id] > 0:
            task.action = start_delayed(task.env, task.run(), delays[task.id])
        else:
            task.action = env.process(task.run())

if __name__ == '__main__':
    env = simpy.Environment()
    taskA = Task('A', 4, env)
    taskB = Task('B', 5, env, previousTasks=[taskA])
    taskC = Task('C', 2, env, previousTasks=[taskB])
    tasks = [taskA, taskB, taskC]
    delays.update(estimate_delays(tasks))
    set_action(tasks)
    env.run(until=20)

В этом случае проект имеет 3 задачи ("A", "B", "C"), и вот дерево:

Start --->A--->B--->C--->End 

B должен начинаться в момент времени: 4 (потому что это продолжительность A). И C, должен начаться в момент времени: 9 (потому что это продолжительность B+A).
Чтобы узнать, какая задача уже выполнена, я создал список, в котором каждая задача добавляет свой идентификатор. Если его собственный идентификатор находится в этом списке, каждая задача удаляется из среды.

Answer 1

Я должен сделать это как комментарий, но у меня нет репутации, чтобы сделать это. Тем не менее, я думаю, что это может помочь с вашей проблемой.

Я не знаком с Simpy, но вы можете сбить с толку триггер и обработчик, который не позволяет выполнить задачу B; проверьте эту ссылку: http://simpy.readthedocs.org/en/latest/api_reference/simpy.events.html