Changeset 143 for MicroThreading/UMicroThreading.pas

Timestamp:

Jan 24, 2011, 4:15:44 PM (14 years ago)

Author:

george

Message:

• Added: Preliminary definition of pool thread for multi threaded scheduling.

File:

• MicroThreading/UMicroThreading.pas (modified) (2 diffs)

MicroThreading/UMicroThreading.pas

@@ -72 +72 @@
   TMicroThreadMethod = class(TMicroThread)
     Method: TMicroThreadEvent;
+    procedure Execute; override;
+  end;
+
+  { TMicroThreadSchedulerPoolThread }
+
+  TMicroThreadSchedulerPoolThread = class(TThread)
+    Scheduler: TMicroThreadScheduler;
     procedure Execute; override;
   end;
@@ -125 +132 @@
 implementation
 
+{ TMicroThreadSchedulerPoolThread }
+
+procedure TMicroThreadSchedulerPoolThread.Execute;
+var
+  ExecutedCount: Integer;
+begin
+  inherited Execute;
+  try
+    repeat
+      ExecutedCount := Scheduler.Execute(10);
+      if ExecutedCount = 0 then Sleep(1);
+    until Terminated;
+  except
+    on E: Exception do
+      //ExceptionHandler(E);
+  end;
+end;
+
 { TMicroThreadMethod }