1:
2:
3:
4:
5:
6:
7:
8:
9:
10:
11:
12:
13:
14:
15:
16:
17:
18:
19:
20:
21:
22:
23:
24:
25:
26:
27:
28:
29:
30:
31:
32:
33:

procedure TPipeServer.AddWorkerThread(Pipe: HPIPE);
var  pstWorker:     TPipeThread;
     ppInfo:        PPipeInfo;
begin

  // Set worker thread
  pstWorker:=nil;

  // Create a new pipe info structure to manage the pipe
  ppInfo:=AllocPipeInfo(Pipe);

  // Resource protection
  try
     // Create the server worker thread
     pstWorker:=TPipeThread.Create(True, FHwnd, FBaseThread, ppInfo^.WriteQueue, FThreadCount, Pipe, ppInfo^.KillEvent);
     // Resource protection
     try
        // Set the OnTerminate handler
        pstWorker.OnTerminate:=RemoveWorkerThread;
     finally
        // Resume the thread
        pstWorker.Resume;
     end;
  except
     // Exception during thread create, remove the client record
     RemoveClient(Pipe);
     // Disconnect and close the pipe handle
     DisconnectAndClose(Pipe);
     // Free the worker thread object
     FreeAndNil(pstWorker);
  end;

end;