Changeset 231 for PinConnection/UCommThread.pas

Timestamp:

Apr 14, 2011, 12:47:57 PM (13 years ago)

Author:

george

Message:

• Modified: MicroThreading replaced by TListedThread classic thread implementation.

File:

• PinConnection/UCommThread.pas (modified) (6 diffs)

PinConnection/UCommThread.pas

@@ -7 +7 @@
 uses
   Classes, SysUtils, blcksock, UCommPin, SyncObjs, UStreamHelper, UCommon,
-  UMicroThreading, DateUtils;
+  DateUtils, UThreading;
 
 type
@@ -16 +16 @@
   { TCommThreadReceiveThread }
 
-  TCommThreadReceiveThread = class(TMicroThread)
+  TCommThreadReceiveThread = class(TListedThread)
   public
     Parent: TCommThread;
@@ -34 +34 @@
     FReceiveThread: TCommThreadReceiveThread;
     FInputBuffer: TMemoryStream;
-    FInputBufferLock: TMicroThreadCriticalSection;
-    FDataAvailable: TMicroThreadEvent;
+    FInputBufferLock: TCriticalSection;
+    FDataAvailable: TEvent;
     procedure ReceiveData(Sender: TCommPin; Stream: TStream);
     procedure ExtReceiveData(Sender: TCommPin; Stream: TStream);
@@ -93 +93 @@
   inherited Create;
   FInputBuffer := TMemoryStream.Create;
-  FInputBufferLock := TMicroThreadCriticalSection.Create;
+  FInputBufferLock := TCriticalSection.Create;
   Ext := TCommPin.Create;
   Ext.OnReceive := ExtReceiveData;
   Pin := TCommPin.Create;
   Pin.OnReceive := ReceiveData;
-  FDataAvailable := TMicroThreadEvent.Create;
+  FDataAvailable := TSimpleEvent.Create;
 end;
 
@@ -122 +122 @@
     with Parent do
     repeat
-      if FDataAvailable.WaitFor(1 * OneMillisecond) = wrSignaled then begin
+      if FDataAvailable.WaitFor(1) = wrSignaled then begin
       try
         FInputBufferLock.Acquire;
@@ -132 +132 @@
         FInputBufferLock.Release;
       end;
-      end else Yield;
+      end; // else Yield;
     until Terminated;
   finally