Changeset 162 for MicroThreading/Demo/UMainForm.pas

Timestamp:

Feb 7, 2011, 1:04:27 PM (14 years ago)

Author:

george

Message:

• Add: MicroThread critical section.
• Add: Thread list to microthread list window.

File:

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

MicroThreading/Demo/UMainForm.pas

@@ -20 +20 @@
     MainForm: TMainForm;
     procedure DoWriteToMemo;
+    constructor Create(CreateSuspended: Boolean;
+      const StackSize: SizeUInt = DefaultStackSize);
+    destructor Destroy; override;
   end;
 
@@ -38 +41 @@
     CheckBox2: TCheckBox;
     CheckBox3: TCheckBox;
+    CheckBox4: TCheckBox;
     CheckBoxUseMainThread: TCheckBox;
     GroupBox1: TGroupBox;
@@ -45 +49 @@
     Label11: TLabel;
     Label12: TLabel;
-    Label13: TLabel;
     Label14: TLabel;
     Label15: TLabel;
     Label16: TLabel;
     Label17: TLabel;
+    Label18: TLabel;
     Label2: TLabel;
     Label3: TLabel;
@@ -58 +62 @@
     Label8: TLabel;
     Label9: TLabel;
-    ListView2: TListView;
     Memo1: TMemo;
     PageControl1: TPageControl;
@@ -66 +69 @@
     SpinEdit4: TSpinEdit;
     SpinEdit5: TSpinEdit;
+    SpinEdit6: TSpinEdit;
     TabSheet1: TTabSheet;
     TabSheet2: TTabSheet;
@@ -83 +87 @@
     procedure CheckBox2Change(Sender: TObject);
     procedure CheckBox3Change(Sender: TObject);
+    procedure CheckBox4Change(Sender: TObject);
     procedure CheckBoxUseMainThreadChange(Sender: TObject);
     procedure FormCreate(Sender: TObject);
@@ -91 +96 @@
     procedure SpinEdit3Change(Sender: TObject);
     procedure SpinEdit5Change(Sender: TObject);
+    procedure SpinEdit6Change(Sender: TObject);
     procedure TimerRedrawTimer(Sender: TObject);
   private
     MicroThreadList: TMicroThreadList;
+    Lock: TMicroThreadCriticalSection;
     LastException: Exception;
     LastExceptionSender: TObject;
@@ -102 +109 @@
     DoWriteToMemo: Boolean;
     DoSleep: Boolean;
+    DoCriticalSection: Boolean;
     RaiseException: Boolean;
     SleepDuration: Integer;
+    CriticalSectionSleepDuration: Integer;
     DoWaitForEvent: Boolean;
     Event: TMicroThreadEvent;
@@ -129 +138 @@
   MicroThreadList := TMicroThreadList.Create(Self);
   UMicroThreading.ExceptionHandler := ShowException;
+  Lock := TMicroThreadCriticalSection.Create;
 end;
 
@@ -280 +290 @@
 end;
 
+procedure TMainForm.CheckBox4Change(Sender: TObject);
+begin
+  CriticalSectionSleepDuration := SpinEdit4.Value;
+  DoCriticalSection := CheckBox4.Checked;
+end;
+
 procedure TMainForm.CheckBoxUseMainThreadChange(Sender: TObject);
 begin
@@ -290 +306 @@
   MainScheduler.Active := False;
   Event.Free;
+  Lock.Free;
 end;
 
@@ -303 +320 @@
 procedure TMainForm.ListView2Data(Sender: TObject; Item: TListItem);
 begin
-  if Item.Index < MainScheduler.ThreadPoolCount then
-  try
-    MainScheduler.ThreadPoolLock.Acquire;
-    with TMicroThreadThread(MainScheduler.ThreadPool[Item.Index]) do begin
-      Item.Caption := IntToStr(ThreadID);
-      Item.SubItems.Add(MicroThreadThreadStateText[State]);
-    end;
-  finally
-    MainScheduler.ThreadPoolLock.Release;
-  end;
 end;
 
@@ -330 +337 @@
 end;
 
+procedure TMainForm.SpinEdit6Change(Sender: TObject);
+begin
+end;
+
 procedure TMainForm.TimerRedrawTimer(Sender: TObject);
 begin
-  if ListView2.Items.Count <> MainScheduler.ThreadPoolCount then
-    ListView2.Items.Count := MainScheduler.ThreadPoolCount;
-  ListView2.Items[-1];
-  ListView2.Refresh;
-
   Label2.Caption := DateTimeToStr(NowPrecise) + ' ' +
     FloatToStr(Frac(NowPrecise / OneSecond));
@@ -369 +375 @@
 begin
   for I := 0 to MainForm.Iterations - 1 do begin
-    try
     Q := 0;
-    while Q < 100 do Inc(Q);
+    while Q < 100000 do Inc(Q);
     if MainForm.DoWriteToMemo then Synchronize(DoWriteToMemo);
     if MainForm.DoWaitForEvent then MainForm.Event.WaitFor(MainForm.WaitForEventDuration * OneMillisecond);
@@ -379 +384 @@
       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;
     Completion := I / MainForm.Iterations;
     Yield;
-
-    except
-      Q := 0;
-      raise  Exception.Create('Exception from microthread');
-    end;
   end;
 end;
@@ -395 +403 @@
 end;
 
+constructor TWorker.Create(CreateSuspended: Boolean; const StackSize: SizeUInt);
+begin
+  inherited;
+end;
+
+destructor TWorker.Destroy;
+begin
+  inherited Destroy;
+end;
+
 end.