Delphi: Потоковый список заданий потока - организация очередей

Я только что реализовал нечто очень похожее.

Я думаю, что вам нужна система пула потоков.

У вас есть пул потоков, содержащий некоторое количество потоков (максимальное количество элементов, которые будут выполняться одновременно). Затем вы создаете объект единицы работы и помещаете его в очередь. Каждый рабочий поток получает первую доступную единицу работы в очереди и выполняет ее. По завершении рабочий поток ожидает, пока в очереди не появятся новые рабочие единицы.

Преимущества этого подхода в том, что вы можете легко контролировать максимальное количество одновременных операций, и вы не создаете и не отбрасываете потоки для каждого операция (что дорого).

Let's say you have a thread which will execute the others, say WorkerThread.

In the WorkerThread you could put the threads to be called in an array of TThread, a TThreadList, TList, basically whichever is more comfortable with you.

Then in a for loop start each of them. Now, since you don't want them to run simoultaneously you have 2 ways to wait for the running thread, either use some flag and listen to the thread's OnTerminate event which when gets fired sets the flag, or use

WaitForSingleObject(Thread.Handle, INFINITE);

Я не совсем понимаю ваш вопрос и действительно не понимаю смысла использования нескольких потоков с последующей сериализацией выполнения ... но вы могли бы сделать это так:

 JobList : TList <TThread>;
 ...
 JobList.Add (TMyCustomThread.Create (True));  // Create suspended
 JobList.Add (TMyOtherThread.Create (True));   // Create suspended
 ...
 for Thread in JobList do
   begin
   Thread.Start;
   Thread.WaitFor;
   end;

Это будет выполнить каждый поток, а затем дождаться завершения потока перед выполнением следующего потока.

В примере кода предполагается, что вы используете D2009 или более позднюю версию (вы не указали в своем вопросе) и что вы создали свои потоки в приостановленном состоянии. Если вы используете старую версию Delphi, вам нужно вызвать Resume вместо Start и заменить общий TList простым TList или массив.

Обратите внимание на утечки памяти в примере кода.

Коллекции Generics TQueue может использоваться в качестве контейнера для отдельных объектов заданий.

Затем рабочий поток выбирает («извлекает») первое задание и выполняет его, а затем продолжает до тех пор, пока очередь не опустеет - тогда выполнение должно быть приостановлено до тех пор, пока в очередь не будет добавлено другое задание, и продолжено.

Вам потребуется реализовать потокобезопасный доступ к очереди для добавления новых заданий.

Вам следует посмотреть OmniThreadLibrary . Это делает рабочие потоки чрезвычайно простыми, и вы в основном просто добавляете для этого задачу; каждый запускается сразу после завершения предыдущего, и библиотека позволяет легко передавать сообщения о состоянии и т. д. обратно в основной поток для обновлений пользовательского интерфейса.