О чём не пишут в книгах по Delphi

 TListenThread = class(TThread)

 private

  // Сообщение, которое нужно добавить в лог.

  // Хранится в отдельном поле, т.к. метод, вызывающийся

  // через Synchronize, не может иметь параметров.

  FMessage: string;

  // Сокет, находящийся в режиме прослушивания

  FServerSocket: TSocket;

  // События нити

  // FEvents[0] используется для остановки нити

  // FEvents[1] связывается с событием FD_ACCEPT

  FEvents: array[0..1] of TWSAEvent;

  // Список нитей клиентов

  FClientThreads: TList;

  // Если True, сервер посылает клиенту сообщения

  // по собственной инициативе

  FServerMsg: Boolean;

  // Вспомогательный метод для вызова через Synchronize

  procedure DoLogMessage;

 protected

  procedure Execute; override;

  // Вывод сообщения в лог главной формы

  procedure LogMessage(const Msg: string);

 public

  constructor Create(ServerSocket: TSocket; ServerMsg: Boolean);

  destructor Destroy; override;

  // Вызывается извне для остановки сервера

  procedure StopServer;

 end;

implementation

uses

 MainServerUnit, ClientThread;

{ TListenThread }

// "Слушающий" сокет создается в главной нити,

// а сюда передается через параметр конструктора

constructor TListenThread.Create(ServerSocket: TSocket; ServerMsg: Boolean);

begin

 FServerSocket := ServerSocket;

 FServerMsg := ServerMsg;

 // Создаем события

 FEvents[0] := WSACreateEvent;

 if FEvents[0] = WSA_INVALID_EVENT then

  raise ESocketError.Create(

   'Ошибка при создании события для сервера:' + GetErrorString);

 FEvents[1] := WSACreateEvent;

 if FEvents[1] = WSA_INVALID_EVENT then

  raise ESocketError.Create(

   'Ошибка при создании события для сервера: ' + GetErrorString);

 if WSAEventSelect(FServerSocket, FEvents[1], FD_ACCEPT) = SOCKET_ERROR then

  raise ESocketError.Create(

   'Ошибка при привязывании серверного сокета к событию: ' + GetErrorString);

 FClientThreads := TList.Create;

 inherited Create(False);

end;

destructor TListenThread.Destroy;

begin

 // Убираем за собой

 FClientThreads.Free;

 WSACloseEvent(FEvents[0]);

 WSACloseEvent(FEvents[1]);

 inherited;

end;

procedure TListenThread.Execute;

var

 // Сокет, созданный для общения с подключившимся клиентом

 ClientSocket: TSocket;

 // Адрес подключившегося клиента

 ClientAddr: TSockAddr;

 ClientAddrLen: Integer;

 NetEvents: TWSANetworkEvents;

 I: Integer;

 WaitRes: Cardinal;

begin

 LogMessage('Сервер начал работу');

 // Начинаем бесконечный цикл

 repeat

  // Ожидание события с 15-секундным тайм-аутом

  WaitRes :=

   WSAWaitForMultipleEvents(2, @FEvents, False, 15000, False);

  case WaitRes of

  WSA_WAIT_EVENT_0:

  // Событие FEvents[0] взведено - это означает, что

  // сервер должен остановиться.

  begin