Оптимизация работы TCP-сервера на Delphi: эффективное создание потоков без Indy

Delphi , ОС и Железо , Windows

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

Проблема приема соединений

При работе с TCP-сервером на Delphi часто возникает задача приема входящих соединений с максимально возможной скоростью. При этом важно обеспечить, чтобы для каждого соединения был выделен отдельный поток для обработки данных. Это позволяет не блокировать основной поток программы и обеспечивает параллельную обработку нескольких соединений.

Пример класса TThread для прослушивания порта

В приведенном ниже коде показан пример класса TListenThread, который отвечает за прием соединений:

procedure TListenThread.Execute;
var
  iSize     : Integer;
begin
  ConnectionAttempts := 0;
  while not Terminated do begin
    iSize := SizeOf(TAddr);
    hClient := Accept(hServer, @TAddr, @iSize);
    if (hClient <> INVALID_SOCKET) then begin
      Inc(ConnectionAttempts);
      SynchIP := inet_ntoa(TAddr.sin_addr);
      Synchronize(WriteToLog); // Обработка лога выполняется очень быстро!
      with TReceiveThread.Create(TRUE) do begin // Создание потока занимает больше всего времени...
        FreeOnTerminate   := TRUE;
        hSocket           := hClient;
        TheForm           := aForm;
        Host              := SynchIP;
        Resume;
      end;
    end;
  end;
end;

Задержка при создании потоков

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

Альтернативный ответ: использование пула потоков

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

Пример пула потоков

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

Использование механизма пула в Indy

Хотя автор вопроса изначально не хотел использовать Indy, данная технология предоставляет компонент TIdThreadMgrPool (Indy 9) или TIdSchedulerOfThreadPool (Indy 10), который позволяет автоматизировать управление потоками и их пулинг.

// Пример назначения пула потоков для TIdTCPServer в Indy 9
TIdTCPServer.ThreadMgr := TIdThreadMgrPool.Create(nil);

Заключение

Использование пула потоков позволяет существенно ускорить работу TCP-сервера на Delphi, минимизируя время на создание новых потоков и оптимизируя использование системных ресурсов. Хотя автор вопроса изначально отвергал использование Indy, его компоненты могут быть полезны для решения поставленной задачи, предоставляя готовые решения для управления потоками.

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

Оптимизация работы TCP-сервера на Delphi, включая создание эффективных потоков для обработки соединений без использования Indy.

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

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

:: Главная :: Windows ::