Создание потоков

program Lr4;
 
{$APPTYPE CONSOLE}
 
uses
  SysUtils,
  Windows,
  Dialogs;
 
type
  Str = array[0..200] of char;
  PThrWriteParams = ^TThrWriteParams;
  TThrWriteParams = record
    PN, Mes: Str;
  end;
 
 
//------------------------------------------------------------------
 
const
 PipeName = '\\\\.\\pipe\\MyPipe';
 
var
  h, hThr1, hThr2: HWND;
  mes: Str;
  ReadStr: Str;
  WriteParams: PThrWriteParams;
  TID: Cardinal;
 
//------------------------------------------------------------------
 
function WriteThread(Param: Pointer):integer;
var
  hPipe: HWND;
  nBytes: Cardinal;
  Params: TThrWriteParams;
begin
 writeln('Write thread started!');
 Params := PThrWriteParams(Param)^;
 
 hPipe := CreateFile(Params.PN,
                     GENERIC_WRITE,
                     0,
                     nil,
                     OPEN_EXISTING,
                     0,
                     0);
 
 if not WriteFile(hPipe, Params.Mes, 100, nBytes, nil) then
   write('WriteFile Error!');
 
 CloseHandle(hPipe);
 EndThread(0);
end;
 
//------------------------------------------------------------------
 
function ReadThread(Parameter: PCardinal):integer;
var
  nBytes: Cardinal;
  hPipe: HWND;
begin
 write('Read thread started!');
 hPipe := Parameter^;
 
 while not ConnectNamedPipe(hPipe, nil) do
   begin
     sleep(1000);
     writeln('Can not connect to pipe!');
   end;
 
 if not ReadFile(hPipe, ReadStr, 100, nBytes, nil) then
   writeln('Can not read data!');
 
 DisconnectNamedPipe(hPipe);
 EndThread(0);
end;
 
begin
 SetLastError(0);
 h := CreateNamedPipe(PipeName,
                      PIPE_ACCESS_DUPLEX,
                      PIPE_TYPE_MESSAGE,
                      100,
                      100,
                      100,
                      0,
                      nil);
 writeln('Write your message:');
 readln(mes);
 
 New(WriteParams);
 WriteParams^.PN := PipeName;
 WriteParams^.Mes := Mes;
 
 hThr1 := BeginThread(nil,
                       0,
                       Addr(WriteFile),
                       PThrWriteParams(WriteParams),
                       0,
                       TID);
  readln;
  writeln(GetLastError);
 
  hThr2 := BeginThread(nil,
                       0,
                       Addr(ReadFile),
                       @h,
                       0,
                       TID);
  readln;
  writeln(GetLastError);
 
 if hThr1 <> 0 then
   CloseHandle(hThr1);
 if hThr2 <> 0 then
   CloseHandle(hThr2);
   
 writeln(ReadStr);
 readln;
end.