Как заставить основной (вызывающий) поток ждать завершения дочернего потока?

Question

Использование: Delphi 10 Seattle, Win32 VCL forms application

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

constructor TWebFileDownloaderThread.Create(CreateSuspended: Boolean; const AWebFileURL, ALocalFilePath: String; 
    ACallBackProc: TProgressCallback; AProxySetting: TProxySetting); 
begin 
    inherited Create(CreateSuspended); 

    FWorkResult := False; 

    FWebFileURL := AWebFileURL; 
    FProxySetting := AProxySetting; 
    FLocalFilePath := ALocalFilePath; 

    FUpdateCallbackProc := ACallBackProc; 
end; 

Основной поток создает и запускает загрузчик нить следующим образом:

procedure TfmMain.DownloadUpdateFromWeb(const AInstallerFileURL: String); 
var 
    internet_file_download_thread: TWebFileDownloaderThread; 
begin 
    internet_file_download_thread := TWebFileDownloaderThread.Create(True, AInstallerFileURL, FUpdateDownloadDir, 
    UpdateProgressCallback, FProxySetting); 

    internet_file_download_thread.OnTerminate := WebFileDownloaderThread_TerminatedMethod; 
    internet_file_download_thread.FreeOnTerminate := True; 
    internet_file_download_thread.Start; 
end; 

Мой конкретный вопрос : Как сделать основной (вызывающий) поток пользовательского интерфейса до тех пор, пока поток загрузчика не завершится, перед созданием нового потока загрузчика, чтобы начать следующую загрузку?

Я считаю, что требуется некоторая форма очереди, но не знаете, как ее реализовать. Ваши советы и советы очень ценятся.

Answer 1

Если я правильно понял, у вас есть список URL-адресов для загрузки и установки (полученный путем предварительной проверки обновлений). Вы хотите загружать обновления с этих URL-адресов и устанавливать их по одному: загрузить обновление 1, установить обновление 1, загрузить обновление 2, установить обновление 2 и т. Д.

Вот возможный дизайн:

В вашем WebFileDownloaderThread_TerminatedMethod, начать установку только загруженное обновление (чтобы основной поток отзывчивый, сделать это в отдельном потоке).

В OnTerminate обработчик монтажника нити, удалите только что запущенном URL (или пометить его как обработанное) и снова начать загрузку следующего, позвонив по телефону DownloadUpdateFromWeb, если список уже не является пустым (или содержит не более необработанных элементов).

(кстати, метод DownloadUpdateFromWeb бы лучше назвать что-то вроде BeginDownloadUpdateFromWeb, чтобы указать его асинхронный характер.)

Answer 2

Вы не должны блокировать основной поток. Поэтому не ждите, пока рабочий поток не завершится. Вместо этого организуйте, чтобы рабочий поток сигнализировал основному потоку, когда он закончил. Например по:

• Отправка сообщения или
• Использование TThread.Synchronize или
• Использование TThread.Queue или
• Работа с OnTerminate событие нити или
• Некоторые другие формы меж- нить связи.

OnTerminate выглядит довольно хорошим вариантом для меня.

Возможно, вы также захотите использовать параллельную библиотеку более высокого уровня. Например, параллельная библиотека RTL или OTL. Таким образом, вы можете избежать путаницы в деталях потоков и позволить параллельной библиотеке заниматься такими вопросами.

Были ли вы сделать это, вы могли бы разработать приложение с производителем/потребительской архитектуры:

1. Создание очереди THREADSAFE.
2. Создайте один или несколько загружаемых потоков, это потребители.
3. Основной поток, производитель, толкает задания загрузки в очередь.
4. Потребительские потоки ожидают очереди и когда они содержат задания, потребительские потоки снимают задания и обрабатывают их, загружая файл.

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