Управление потоками

← →
Alibaba © (2004-10-15 04:53) [0]

Господа, такая ситуация:

Есть главный поток
TThMaster = class(TThread)
...
end;
thMaster: TThMaster;

Есть N дополнительных потоков
TThDepend = class(TThread)
...
end;
thDepend: array[0..N] of TThDepend;

Есть список задач
TTask = class
...
end;
ListTask: TList

Список задач время от времени пополняется
ListTask.Add(TTask.Create(...))
и запускается главный поток
thMaster.Resume

Главный поток проверяет если есть нерешенные задачи в очереди и свободный дополнительный поток (СДП), то передаем СДП задачу, и запускаем СДП (thDepend.Resume).
И так до тех пор пока не останется нерешенных задач или все потоки заняты.
После этого главный поток засыпает (Suspend)

Если СДП завершил работу, то он должен разбудить главный поток (thMaster.Resume). Главный поток раздает задачи (см. предыдущий абзац)

Главный поток могут будить два события:
- появилась новая задача
- какой-либо из дополнительных потоков завершил работу

В чем проблема?
Бывает такая ситуация, что главный поток занимается раздачей заданий и в это время один из дополнительных потоков сообщает ему что он все посчитал (thMaster.Resume) - происходит ошибка.

Как сделать, что-бы если главный поток работает, а дополнительный хочет ему что-то сказать, то что-бы дополнительный подождал?

← →
Ozone © (2004-10-15 07:35) [1]

WaitForSingleObject?

Управление потоками Найти похожие ветки