Changeset 141 for MicroThreading/UMicroThreading.pas

Timestamp:

Jan 24, 2011, 8:49:56 AM (13 years ago)

Author:

george

Message:

• Added: Scheduler Start and Stop methods.

File:

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

MicroThreading/UMicroThreading.pas

@@ -9 +9 @@
   {$IFDEF Windows}Windows,{$ENDIF}
   {$IFDEF Linux}BaseUnix, UnixUtil, Unix,{$ENDIF}
-  Classes, SysUtils, Contnrs, SyncObjs, DateUtils, Dialogs;
+  Classes, SysUtils, Contnrs, SyncObjs, DateUtils, Dialogs, Forms;
 
 type
@@ -66 +66 @@
     FExecuteCount: Integer;
     FExecutedCount: Integer;
+    FTerminated: Boolean;
     function GetMicroThreadCount: Integer;
     procedure Yield(MicroThread: TMicroThread);
@@ -76 +77 @@
     destructor Destroy; override;
     function Execute(Count: Integer): Integer;
+    procedure Start;
+    procedure Stop;
     property MicroThreadCount: Integer read GetMicroThreadCount;
     property FreeMicroThreadOnFinish: Boolean read FFreeMicroThreadOnFinish
@@ -167 +170 @@
 destructor TMicroThreadScheduler.Destroy;
 begin
+  FTerminated := True;
   ThreadPool.Free;
   MicroThreads.Free;
@@ -179 +183 @@
   Yield(nil);
   Result := FExecutedCount;
+end;
+
+procedure TMicroThreadScheduler.Start;
+var
+  Executed: Integer;
+begin
+  FTerminated := False;
+  repeat
+    Executed := Execute(10);
+    Application.ProcessMessages;
+    if Executed = 0 then Sleep(1);
+  until FTerminated;
+end;
+
+procedure TMicroThreadScheduler.Stop;
+begin
+  FTerminated := True;
 end;