Refractoring, Reformatting and minor Fixes

Warfley · Feb 18, 2020 · 164bb61 · 164bb61
1 parent b2945c9
commit 164bb61
Show file tree

Hide file tree

Showing 3 changed files with 168 additions and 103 deletions.
diff --git a/example.lpr b/example.lpr
@@ -72,12 +72,12 @@   TSocketHandler = class(TThreadedWebsocketHandler)
 
   procedure TSocketHandler.MessageRecieved(Sender: TObject);
   var
-    Messages: TMessageOwnerList;
+    Messages: TWebsocketMessageOwnerList;
     m: TWebsocketMessage;
     Comm: TWebsocketCommunincator;
   begin
     Comm := TWebsocketCommunincator(Sender);
-    Messages := TMessageOwnerList.Create(True);
+    Messages := TWebsocketMessageOwnerList.Create(True);
     try
       Comm.GetUnprocessedMessages(Messages);
       for m in Messages do

diff --git a/utilities.pas b/utilities.pas
@@ -44,6 +44,7 @@     TPool = class(specialize TVector<T>);
 
   TPoolableThread = class(TThread)
   private
+    FDoTerminate: boolean;
     FIsIdle: boolean;
   protected
     procedure DoExecute; virtual;
@@ -53,6 +54,7 @@   TPoolableThread = class(TThread)
       const StackSize: SizeUInt = DefaultStackSize);
     procedure Restart; virtual;
     property isIdle: boolean read FIsIdle;
+    property DoTerminate: boolean read FDoTerminate write FDoTerminate;
   end;
 
   { TPoolableThreadFactory }
@@ -403,12 +405,16 @@ procedure TPoolableThread.Execute;
       TThread.Yield;
     end;
     DoExecute;
-    FIsIdle := True;
+    if FDoTerminate then
+      self.Terminate
+    else
+      FIsIdle := True;
   end;
 end;
 
 constructor TPoolableThread.Create(CreateSuspended: boolean; const StackSize: SizeUInt);
 begin
+  FDoTerminate := False;
   if CreateSuspended then
     FIsIdle := True
   else