Улучшение взаимодействия потоков в многофайловых приложениях на Delphi и Pascal: методы синхронизации и отображения прогресса загрузки

Delphi , Компоненты и Классы , Потоки

Улучшение взаимодействия потоков в многофайловых приложениях на Delphi и Pascal: методы синхронизации и отображения прогресса загрузки

В процессе разработки многофайловых приложений на Delphi и Pascal часто возникает необходимость в выполнении задач параллельно для ускорения процесса загрузки данных. Одним из ключевых моментов является синхронизация работы потоков и отображение прогресса загрузки данных, что особенно важно для пользовательского опыта.

Проблема и вопрос

Разработчик сталкивается с проблемой некорректного отображения прогресса загрузки файлов в многофайловом приложении. При использовании класса IdHTTP и его событий, связанных с чтением данных, возникает ситуация, когда прогресс загрузки не соответствует фактически загруженным данным и обновляется очень медленно. Кроме того, добавление сообщений для обновления прогресс-бара приводит к тому, что процесс загрузки не останавливается.

Контекст

В приложении используется главный поток, который создаёт множество вторичных потоков для загрузки данных. Каждый поток имеет свой объект IdHTTP и обработчик события OnWork, который должен обновлять прогресс загрузки. Однако, сообщения для обновления статуса загрузки отправляются во все окна системы, что является неэффективным.

Подтверждённый ответ

Для решения проблемы необходимо использовать функцию PostMessage вместо SendMessage, чтобы не замедлять работу вторичных потоков. Важно не использовать глобальные переменные для отслеживания прогресса, а также не отправлять сообщения во все окна системы. Вместо этого, каждый вторичный поток должен отправлять свой текущий статус в главный поток, который будет обновлять прогресс загрузки.

Альтернативный ответ и примеры кода

Приведём пример реализации, которая решает описанную проблему:

unit StatusUpdates;

interface

type
  PStatus = ^TStatus;
  TStatus = record
    BytesDownloadedThisTime: Int64;
    BytesDownloadedSoFar: Int64;
    MaxBytesBeingDownloaded: Int64;
  end;

var
  StatusUpdateWnd: HWND;

implementation

end.

// В главном потоке
procedure TMainForm.FormCreate(Sender: TObject);
begin
  StatusUpdateWnd := AllocateHWnd(StatusWndProc);
end;

procedure TMainForm.FormDestroy(Sender: TObject);
begin
  if StatusUpdateWnd <> 0 then
  begin
    DeallocateHWnd(StatusUpdateWnd);
    StatusUpdateWnd := 0;
  end;
end;

procedure TMainForm.StatusWndProc(var Message: TMessage);
var
  Status: PStatus;
begin
  if Message.Msg = MyMessage then
  begin
    Status := PStatus(Message.LParam);
    try
      // Обновление прогресс-бара
      if Status.BytesDownloadedThisTime > 0 then
      begin
        Inc(TotalDownloaded, Status.BytesDownloadedThisTime);
        ProgressBar1.Position := TotalDownloaded;
      end;
    finally
      Dispose(Status);
    end;
  end
  else
    Message.Result := DefWindowProc(StatusUpdateWnd, Message.Msg, Message.WParam, Message.LParam);
end;

// В вторичном потоке
procedure TSecondaryThread.PostStatus(BytesThisTime: Int64);
var
  Status: PStatus;
begin
  New(Status);
  Status.BytesDownloadedThisTime := BytesThisTime;
  Status.BytesDownloadedSoFar := FTotalBytes;
  Status.MaxBytesBeingDownloaded := FMaxBytes;
  if not PostMessage(StatusUpdateWnd, MyMessage, 2, LPARAM(Status)) then
    Dispose(Status);
end;

procedure TSecondaryThread.IdHTTPWorkBegin(ASender: TObject; AWorkMode: TWorkMode; AWorkCountMax: Int64);
begin
  if AWorkMode = wmRead then
  begin
    FTotalBytes := 0;
    FMaxBytes := AWorkCountMax;
    PostStatus(0);
  end;
end;

procedure TSecondaryThread.IdHTTPWork(ASender: TObject; AWorkMode: TWorkMode; AWorkCount: Int64);
var
  BytesThisTime: Int64;
begin
  if AWorkMode = wmRead then
  begin
    BytesThisTime := AWorkCount - FTotalBytes;
    FTotalBytes := AWorkCount;
    PostStatus(BytesThisTime);
  end;
end;

Заключение

В данной статье рассмотрены методы синхронизации и отображения прогресса загрузки данных в многофайловых приложениях на Delphi и Pascal. Важно использовать правильные подходы для взаимодействия потоков, чтобы обеспечить корректное обновление статуса загрузки и избежать ошибок, связанных с блокировками и гонками данных. Приведённые примеры кода демонстрируют, как можно организовать эффективную работу с потоками, используя PostMessage и правильное управление памятью.

Создано по материалам из источника по ссылке.

Улучшение взаимодействия потоков в многофайловых приложениях на Delphi и Pascal требует правильной синхронизации и отображения прогресса загрузки, чтобы обеспечить эффективную работу и корректное отображение статуса загрузки данных для пользователя.

Комментарии и вопросы

Получайте свежие новости и обновления по Object Pascal, Delphi и Lazarus прямо в свой смартфон. Подпишитесь на наш Telegram-канал delphi_kansoftware и будьте в курсе последних тенденций в разработке под Linux, Windows, Android и iOS

:: Главная :: Потоки ::