Changeset 158 for MicroThreading/Demo/UMainForm.pas

Timestamp:

Jan 28, 2011, 9:10:16 PM (14 years ago)

Author:

george

Message:

• Fixed: WaitForEvent functionality. Now TEvent.WaitFor will chane microthread to blocked state with defined timeout. TEvent.SetSignal method will unblock all waiting microthreads.

File:

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

MicroThreading/Demo/UMainForm.pas

@@ -11 +11 @@
 type
 
+  TMainForm = class;
+
+  { TWorker }
+
+  TWorker = class(TMicroThread)
+    procedure Execute; override;
+  private
+    MainForm: TMainForm;
+    procedure DoWriteToMemo;
+  end;
+
   { TMainForm }
 
@@ -16 +27 @@
     Button1: TButton;
     Button2: TButton;
+    Button3: TButton;
     ButtonAddWorkers: TButton;
     ButtonClearMicroThreads: TButton;
@@ -21 +33 @@
     ButtonSchedulerStartStop: TButton;
     ButtonShowThreadId: TButton;
+    CheckBox1: TCheckBox;
+    CheckBox2: TCheckBox;
+    CheckBox3: TCheckBox;
     CheckBoxUseMainThread: TCheckBox;
     GroupBox1: TGroupBox;
     GroupBox2: TGroupBox;
+    GroupBox3: TGroupBox;
     Label1: TLabel;
     Label10: TLabel;
@@ -29 +45 @@
     Label12: TLabel;
     Label13: TLabel;
+    Label14: TLabel;
+    Label15: TLabel;
+    Label16: TLabel;
+    Label17: TLabel;
     Label2: TLabel;
     Label3: TLabel;
@@ -44 +64 @@
     SpinEdit2: TSpinEdit;
     SpinEdit3: TSpinEdit;
+    SpinEdit4: TSpinEdit;
+    SpinEdit5: TSpinEdit;
     TabSheet1: TTabSheet;
     TabSheet2: TTabSheet;
@@ -49 +71 @@
     TimerRedraw: TTimer;
     procedure Button1Click(Sender: TObject);
+    procedure Button3Click(Sender: TObject);
     procedure ButtonSchedulerStartStopClick(Sender: TObject);
     procedure Button2Click(Sender: TObject);
@@ -55 +78 @@
     procedure ButtonShowThreadIdClick(Sender: TObject);
     procedure ButtonClearMicroThreadsClick(Sender: TObject);
+    procedure CheckBox1Change(Sender: TObject);
+    procedure CheckBox2Change(Sender: TObject);
+    procedure CheckBox3Change(Sender: TObject);
     procedure CheckBoxUseMainThreadChange(Sender: TObject);
     procedure FormCreate(Sender: TObject);
@@ -63 +89 @@
     procedure SpinEdit2Change(Sender: TObject);
     procedure SpinEdit3Change(Sender: TObject);
+    procedure SpinEdit5Change(Sender: TObject);
     procedure TimerRedrawTimer(Sender: TObject);
   private
-    procedure Worker(MicroThread: TMicroThread);
-    procedure WorkerDoWrite;
     procedure WorkerSubRoutine;
   public
+    DoWriteToMemo: Boolean;
+    DoSleep: Boolean;
+    SleepDuration: Integer;
+    DoWaitForEvent: Boolean;
+    Event: TMicroThreadEvent;
+    WaitForEventDuration: Integer;
     Iterations: Integer;
   end;
@@ -88 +119 @@
   ListView1.DoubleBuffered := True;
   Label6.Caption := IntToStr(GetLogicalProcessorCount);
+  Event := TMicroThreadEvent.Create;
 end;
 
@@ -107 +139 @@
 begin
   Memo1.Clear;
+end;
+
+procedure TMainForm.Button3Click(Sender: TObject);
+begin
+  Event.SetEvent;
 end;
 
@@ -165 +202 @@
 var
   I: Integer;
+  NewWorker: TWorker;
 begin
   //Scheduler.FMicroThreads.Clear;
-  for I := 0 to SpinEdit1.Value - 1 do
-    MainScheduler.AddMethod(Worker);
+  for I := 0 to SpinEdit1.Value - 1 do begin
+    NewWorker := TWorker.Create(True);
+    NewWorker.MainForm := Self;
+    NewWorker.Start;
+  end;
 end;
 
@@ -203 +244 @@
 end;
 
+procedure TMainForm.CheckBox1Change(Sender: TObject);
+begin
+  SleepDuration := SpinEdit4.Value;
+  DoSleep := CheckBox1.Checked;
+end;
+
+procedure TMainForm.CheckBox2Change(Sender: TObject);
+begin
+  DoWriteToMemo := CheckBox2.Checked;
+end;
+
+procedure TMainForm.CheckBox3Change(Sender: TObject);
+begin
+  DoWaitForEvent := CheckBox3.Checked;
+  WaitForEventDuration := SpinEdit5.Value;
+end;
+
 procedure TMainForm.CheckBoxUseMainThreadChange(Sender: TObject);
 begin
@@ -211 +269 @@
 begin
   MainScheduler.Active := False;
+  Event.Free;
 end;
 
@@ -216 +275 @@
 begin
   Iterations := SpinEdit3.Value;
-  SpinEdit2.Value := 20;
+  SpinEdit2.Value := 6;
   ButtonAddWorkers.Click;
   ButtonSchedulerStartStop.Click;
+  Label16.Caption := IntToStr(MainThreadID);
 end;
 
@@ -267 +327 @@
 end;
 
+procedure TMainForm.SpinEdit5Change(Sender: TObject);
+begin
+
+end;
+
 procedure TMainForm.TimerRedrawTimer(Sender: TObject);
 begin
@@ -290 +355 @@
 end;
 
-procedure TMainForm.Worker(MicroThread: TMicroThread);
+procedure TWorker.Execute;
 var
   I: Integer;
   Q: Integer;
 begin
-  with MicroThread do begin
-    //Memo1.Lines.Add('Worker ' + IntToStr(Id));
-    for I := 0 to Iterations - 1 do begin
-      Q := 0;
-      while Q < 100 do Inc(Q);
-      //Synchronize(WorkerDoWrite);
-      //Memo1.Lines.Add(IntToStr(Id) + ': ' + IntToStr(I) + ' ' +
-      //  FloatToStr(ExecutionTime));
-      Completion := I / Iterations;
-      //MTSleep(1000 * OneMillisecond);
-      Yield;
-      //WorkerSubRoutine;
-    end;
-  end;
-end;
-
-procedure TMainForm.WorkerDoWrite;
-begin
-  //Memo1.Lines.Add('.');
+  for I := 0 to MainForm.Iterations - 1 do begin
+    Q := 0;
+    while Q < 100 do Inc(Q);
+    if MainForm.DoWriteToMemo then Synchronize(DoWriteToMemo);
+    if MainForm.DoWaitForEvent then MainForm.Event.WaitFor(MainForm.WaitForEventDuration * OneMillisecond);
+    if MainForm.DoSleep then MTSleep(MainForm.SleepDuration * OneMillisecond);
+    //WorkerSubRoutine;
+    Completion := I / MainForm.Iterations;
+    Yield;
+  end;
+end;
+
+procedure TWorker.DoWriteToMemo;
+begin
+  MainForm.Memo1.Lines.Add(IntToStr(Id) + ': ' + IntToStr(Trunc(Completion * 100)) + ' %');
 end;