Changeset 414 for trunk/Packages/PinConnection/CommThread.pas

Timestamp:

Jan 10, 2025, 4:24:19 PM (7 hours ago)

Author:

chronos

Message:

• Modified: Lowered idle CPU consumption.

File:

• trunk/Packages/PinConnection/CommThread.pas (modified) (8 diffs)

trunk/Packages/PinConnection/CommThread.pas

@@ -12 +12 @@
   TReceiveDataEvent = procedure(Stream: TMemoryStream) of object;
 
-  { TCommThreadReceiveThread }
-
-  TCommThreadReceiveThread = class(TTermThread)
+  { TCommThreadReceiveDataThread }
+
+  TCommThreadReceiveDataThread = class(TTermThread)
   public
     Parent: TCommThread;
@@ -24 +24 @@
   end;
 
+  { TCommThreadReceiveStatusThread }
+
+  TCommThreadReceiveStatusThread = class(TTermThread)
+  public
+    Parent: TCommThread;
+    Stream: TBinarySerializer;
+    procedure Execute; override;
+    constructor Create(CreateSuspended: Boolean;
+      const StackSize: SizeUInt = DefaultStackSize);
+    destructor Destroy; override;
+  end;
+
   { TCommThread }
 
@@ -29 +41 @@
   private
     //FOnReceiveData: TReceiveDataEvent;
-    FReceiveThread: TCommThreadReceiveThread;
+    FReceiveDataThread: TCommThreadReceiveDataThread;
+    FReceiveStatusThread: TCommThreadReceiveStatusThread;
     FInputBuffer: TBinarySerializer;
     FInputBufferLock: TCriticalSection;
@@ -91 +104 @@
 
   if AValue then begin
-    FReceiveThread := TCommThreadReceiveThread.Create(True);
-    FReceiveThread.FreeOnTerminate := False;
-    FReceiveThread.Parent := Self;
-    FReceiveThread.Name := 'CommThread';
-    FReceiveThread.Start;
+    FReceiveDataThread := TCommThreadReceiveDataThread.Create(True);
+    FReceiveDataThread.FreeOnTerminate := False;
+    FReceiveDataThread.Parent := Self;
+    FReceiveDataThread.Name := 'CommThreadData';
+    FReceiveDataThread.Start;
+
+    FReceiveStatusThread := TCommThreadReceiveStatusThread.Create(True);
+    FReceiveStatusThread.FreeOnTerminate := False;
+    FReceiveStatusThread.Parent := Self;
+    FReceiveStatusThread.Name := 'CommThreadStatus';
+    FReceiveStatusThread.Start;
   end else begin
-    FreeAndNil(FReceiveThread);
+    FreeAndNil(FReceiveDataThread);
+    FreeAndNil(FReceiveStatusThread);
   end;
   inherited;
@@ -134 +154 @@
 end;
 
-{ TCommThreadReceiveThread }
-
-procedure TCommThreadReceiveThread.Execute;
-var
-  TempStatus: Integer;
-  DoSleep: Boolean;
+{ TCommThreadReceiveDataThread }
+
+procedure TCommThreadReceiveDataThread.Execute;
 begin
   with Parent do
   repeat
-    DoSleep := True;
     // Check if new data arrived
-    if FDataAvailable.WaitFor(0) = wrSignaled then begin
-      DoSleep := False;
+    if FDataAvailable.WaitFor(100) = wrSignaled then begin
       try
         FInputBufferLock.Acquire;
@@ -157 +172 @@
       Pin.Send(Stream.List);
     end;
-
+  until Terminated;
+end;
+
+constructor TCommThreadReceiveDataThread.Create(CreateSuspended: Boolean;
+  const StackSize: SizeUInt);
+begin
+  inherited;
+  Stream := TBinarySerializer.Create;
+  Stream.List := TListByte.Create;
+  Stream.OwnsList := True;
+end;
+
+destructor TCommThreadReceiveDataThread.Destroy;
+begin
+  FreeAndNil(Stream);
+  inherited;
+end;
+
+{ TCommThreadReceiveStatusThread }
+
+procedure TCommThreadReceiveStatusThread.Execute;
+var
+  TempStatus: Integer;
+begin
+  with Parent do
+  repeat
     // Check if state changed
-    if FStatusEvent.WaitFor(0) = wrSignaled then begin
-      DoSleep := False;
+    if FStatusEvent.WaitFor(100) = wrSignaled then begin
       try
         FInputBufferLock.Acquire;
@@ -170 +209 @@
       Pin.Status := TempStatus;
     end;
-    if not Terminated and DoSleep then begin
-      Sleep(1);
-    end;
   until Terminated;
 end;
 
-constructor TCommThreadReceiveThread.Create(CreateSuspended: Boolean;
+constructor TCommThreadReceiveStatusThread.Create(CreateSuspended: Boolean;
   const StackSize: SizeUInt);
 begin
@@ -185 +221 @@
 end;
 
-destructor TCommThreadReceiveThread.Destroy;
+destructor TCommThreadReceiveStatusThread.Destroy;
 begin
   FreeAndNil(Stream);