type
 TServerSocket =  class (TObject)
 private
   ...
   FCountClientSocket:Integer;
 public
   ...
 end;

function TServerSocket.ListenThread (ServerSocket:TSocket): Integer;
 var ClientSocket: TSocket;
 ClientAddr: TSockAddr;
 ClientAddrLen: Integer;
 P:PClientThread;
 FClientThreadID:DWord;
 //
 hTime:PTimeVal;
 SetR:TFDSet;
begin
 FCountClientSocket:=0;
 repeat
   New(hTime);
   hTime^.tv_sec:=0;
   hTime^.tv_usec:=300000;
   FD_ZERO(SetR);
   FD_Set(ServerSocket,SetR);
   if Select(0,@SetR,nil,nil,hTime)<>0 then
   begin
     if FD_IsSet(ServerSocket,SetR) then
     begin
       ClientAddrLen  := SizeOf(ClientAddr);
       ClientSocket   := Accept(ServerSocket, @ClientAddr, @ClientAddrLen);
       if ClientSocket = INVALID_SOCKET then Break;
       if FCountClientSocket = 0 then
       begin
         // увеличиваем кол-во потоков клиентов
         EnterCriticalSection(FRTLBusy);
         try
           Inc(FCountClientSocket);
         finally
           LeaveCriticalSection(FRTLBusy);
         end;
         //
         // новый поток для работы с клиентом
         New(P);
         P^.SelfUnit     := Self;
         P^.ClientSocket := ClientSocket;
         P^.ClientAddr   := ClientAddr;
         CloseHandle(BeginThread(nil,0,@MsgClientThread,P,0,FClientThreadID));
       end else
       begin  // закрыть сокет, которые пытается подключиться
         Shutdown(ClientSocket,SD_BOTH);
         CloseSocket(ClientSocket);
       end;
     end;
   end;
   Dispose(hTime);
   //смотрим на Abort
   case WaitForSingleObject(FAbort,100) of
     WAIT_OBJECT_0 : Break;
   end;
 until False;
 Shutdown(ServerSocket, SD_BOTH);
 CloseSocket(ServerSocket);
 Result:=0;
end;

function TServerSocket.ClientThread(ClientSocket: TSocket;
 ClientAddr: TSockAddr): Integer;
begin
 ... // работаем
 //
 Shutdown(ClientSocket,SD_BOTH);
 CloseSocket(ClientSocket);
 // уменьшаем кол-во потоков клиентов
 EnterCriticalSection(FRTLBusy);
 try
  Dec(FCountClientSocket);
 finally
   LeaveCriticalSection(FRTLBusy);
 end;
 Result:=0;
end;