Changeset 154 for MicroThreading/Demo/UMainForm.pas

Timestamp:

Jan 27, 2011, 2:15:57 PM (14 years ago)

Author:

george

Message:

• Add: Not completed event signaling support.

File:

• MicroThreading/Demo/UMainForm.pas (modified) (13 diffs)

MicroThreading/Demo/UMainForm.pas

@@ -7 +7 @@
 uses
   Classes, SysUtils, FileUtil, Forms, Controls, Graphics, Dialogs, StdCtrls,
-  ComCtrls, ExtCtrls, Spin, UMicroThreading, Coroutine, DateUtils, UPlatform;
+  ComCtrls, ExtCtrls, Spin, UMicroThreading, DateUtils, UPlatform;
 
 type
@@ -67 +67 @@
     procedure Worker(MicroThread: TMicroThread);
     procedure WorkerDoWrite;
+    procedure WorkerSubRoutine;
   public
     Iterations: Integer;
-    Scheduler: TMicroThreadScheduler;
   end;
 
@@ -85 +85 @@
 procedure TMainForm.FormCreate(Sender: TObject);
 begin
-  Scheduler := TMicroThreadScheduler.Create;
   DoubleBuffered := True;
   ListView1.DoubleBuffered := True;
@@ -97 +96 @@
   if ButtonSchedulerStartStop.Caption = 'Start scheduler' then begin
     ButtonSchedulerStartStop.Caption := 'Stop scheduler';
-    Scheduler.ThreadPoolSize := SpinEdit2.Value;
-    Scheduler.Active := True;
+    MainScheduler.ThreadPoolSize := SpinEdit2.Value;
+    MainScheduler.Active := True;
   end else begin
     ButtonSchedulerStartStop.Caption := 'Start scheduler';
-    Scheduler.Active := False;
+    MainScheduler.Active := False;
   end;
 end;
@@ -169 +168 @@
   //Scheduler.FMicroThreads.Clear;
   for I := 0 to SpinEdit1.Value - 1 do
-    Scheduler.AddMethod(Worker);
+    MainScheduler.AddMethod(Worker);
 end;
 
@@ -197 +196 @@
 begin
   try
-    Scheduler.MicroThreadsLock.Acquire;
-    Scheduler.MicroThreads.Clear;
+    MainScheduler.MicroThreadsLock.Acquire;
+    MainScheduler.MicroThreads.Clear;
   finally
-    Scheduler.MicroThreadsLock.Release;
+    MainScheduler.MicroThreadsLock.Release;
   end;
 end;
@@ -206 +205 @@
 procedure TMainForm.CheckBoxUseMainThreadChange(Sender: TObject);
 begin
-  Scheduler.UseMainThread := CheckBoxUseMainThread.Checked;
+  MainScheduler.UseMainThread := CheckBoxUseMainThread.Checked;
 end;
 
 procedure TMainForm.FormClose(Sender: TObject; var CloseAction: TCloseAction);
 begin
-  Scheduler.Active := False;
+  MainScheduler.Active := False;
 end;
 
 procedure TMainForm.FormDestroy(Sender: TObject);
 begin
-  Scheduler.Free;
+  MainScheduler.Free;
 end;
 
@@ -227 +226 @@
 begin
   try
-    Scheduler.MicroThreadsLock.Acquire;
-    if Item.Index < Scheduler.MicroThreads.Count then
-    with TMicroThread(Scheduler.MicroThreads[Item.Index]) do begin
+    MainScheduler.MicroThreadsLock.Acquire;
+    if Item.Index < MainScheduler.MicroThreads.Count then
+    with TMicroThread(MainScheduler.MicroThreads[Item.Index]) do begin
       Item.Caption := IntToStr(Id);
       Item.SubItems.Add(Name);
@@ -240 +239 @@
     end;
   finally
-    Scheduler.MicroThreadsLock.Release;
+    MainScheduler.MicroThreadsLock.Release;
   end;
 end;
@@ -246 +245 @@
 procedure TMainForm.SpinEdit2Change(Sender: TObject);
 begin
-  Scheduler.ThreadPoolSize := SpinEdit2.Value;
+  MainScheduler.ThreadPoolSize := SpinEdit2.Value;
 end;
 
@@ -256 +255 @@
 procedure TMainForm.TimerRedrawTimer(Sender: TObject);
 begin
-  if ListView1.Items.Count <> Scheduler.MicroThreadCount then
-    ListView1.Items.Count := Scheduler.MicroThreadCount;
+  if ListView1.Items.Count <> MainScheduler.MicroThreadCount then
+    ListView1.Items.Count := MainScheduler.MicroThreadCount;
   ListView1.Items[-1];
   ListView1.Refresh;
   Label2.Caption := DateTimeToStr(NowPrecise) + ' ' +
     FloatToStr(Frac(NowPrecise / OneSecond));
-  Label9.Caption := IntToStr(Scheduler.ThreadPoolCount);
-  Label10.Caption := IntToStr(Scheduler.MicroThreadCount);
+  Label9.Caption := IntToStr(MainScheduler.ThreadPoolCount);
+  Label10.Caption := IntToStr(MainScheduler.MicroThreadCount);
 end;
 
@@ -271 +270 @@
   ButtonAddWorkers.Click;
   ButtonSchedulerStartStop.Click;
+end;
+
+procedure TMainForm.WorkerSubRoutine;
+begin
+  MTSleep(1 * OneMillisecond);
 end;
 
@@ -287 +291 @@
       //  FloatToStr(ExecutionTime));
       Completion := I / Iterations;
-      //Sleep(1 * Id * OneMillisecond);
+      //MTSleep(1 * Id * OneMillisecond);
       Yield;
+      WorkerSubRoutine;
     end;
   end;