Changeset 166 for MicroThreading/Demo/UMainForm.pas

Timestamp:

Feb 9, 2011, 1:35:28 PM (13 years ago)

Author:

george

Message:

• Modified: Sync functions now not accept main thread context. Instead MainScheduler.AddMethod have to by used.

File:

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

MicroThreading/Demo/UMainForm.pas

@@ -33 +33 @@
     Button4: TButton;
     Button5: TButton;
+    Button6: TButton;
     ButtonAddWorkers: TButton;
     ButtonClearMicroThreads: TButton;
@@ -77 +78 @@
     procedure Button4Click(Sender: TObject);
     procedure Button5Click(Sender: TObject);
+    procedure Button6Click(Sender: TObject);
     procedure ButtonSchedulerStartStopClick(Sender: TObject);
     procedure Button2Click(Sender: TObject);
@@ -105 +107 @@
     procedure ShowException(Sender: TObject; E: Exception);
     procedure DoShowException;
+    procedure MethodWorker;
   public
     DoWriteToMemo: Boolean;
@@ -171 +174 @@
 begin
   RaiseException := True;
+end;
+
+procedure TMainForm.Button6Click(Sender: TObject);
+var
+  I: Integer;
+begin
+  //Scheduler.FMicroThreads.Clear;
+  for I := 0 to SpinEdit1.Value - 1 do begin
+    MainScheduler.AddMethod(MethodWorker, False);
+  end;
 end;
 
@@ -363 +376 @@
   ShowMessage('Exception "' + LastException.Message + '" in class "' +
     LastExceptionSender.ClassName + '"')
+end;
+
+procedure TMainForm.MethodWorker;
+var
+  I: Integer;
+  Q: Integer;
+begin
+  for I := 0 to MainForm.Iterations - 1 do begin
+    Q := 0;
+    while Q < 100000 do Inc(Q);
+    if MainForm.DoWriteToMemo then
+      MainForm.Memo1.Lines.Add(IntToStr(GetCurrentMicroThread.Id) + ': ' + IntToStr(Trunc(GetCurrentMicroThread.Completion * 100)) + ' %');
+    if MainForm.DoWaitForEvent then MainForm.Event.WaitFor(MainForm.WaitForEventDuration * OneMillisecond);
+    if MainForm.DoSleep then MTSleep(MainForm.SleepDuration * OneMillisecond);
+    if MainForm.RaiseException then begin
+      MainForm.RaiseException := False;
+      raise Exception.Create('Exception from microthread');
+    end;
+    if MainForm.DoCriticalSection then begin
+      try
+        MainForm.Lock.Acquire;
+        MTSleep(MainForm.CriticalSectionSleepDuration * OneMillisecond);
+      finally
+        MainForm.Lock.Release;
+      end;
+    end;
+    //WorkerSubRoutine;
+    GetCurrentMicroThread.Completion := I / MainForm.Iterations;
+    GetCurrentMicroThread.Yield;
+  end;
 end;