О чём не пишут в книгах по 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

LogMessage('Сервер получил сигнал завершения работы');