Changeset 168 for MicroThreading/UMicroThreading.pas

Timestamp:

Feb 10, 2011, 4:10:59 PM (13 years ago)

Author:

george

Message:

• Added: Context menu in microthreads list to show microthread call stack.

File:

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

MicroThreading/UMicroThreading.pas

@@ -141 +141 @@
     property Manager: TMicroThreadManager read FManager write SetManager;
     property StackUsed: Integer read GetStackUsed;
+    property BasePointer: Pointer read FBasePointer;
   end;
 
@@ -391 +392 @@
     Dec(FCounter);
     if FMicroThreads.Count > 0 then begin
-      // Release one waiting micro thread and lower counter
+      // Release one waiting micro thread
       TMicroThread(FMicroThreads[0]).FState := tsWaiting;
       FMicroThreads.Delete(0);
@@ -435 +436 @@
   Form := TMicroThreadListForm.Create(Self);
 end;
-
-
 
 { TMicroThreadMethod }
@@ -797 +796 @@
 begin
   try
+    FScheduler.FMicroThreadsLock.Acquire;
     CriticalSection.Lock.Acquire;
     Inc(CriticalSection.FCounter);
@@ -805 +805 @@
       try
         CriticalSection.Lock.Release;
+        FScheduler.FMicroThreadsLock.Release;
         Yield;
       finally
+        FScheduler.FMicroThreadsLock.Acquire;
         CriticalSection.Lock.Acquire;
       end;
@@ -812 +814 @@
   finally
     CriticalSection.Lock.Release;
+    FScheduler.FMicroThreadsLock.Release;
   end;
 end;
@@ -845 +848 @@
   const StackSize: SizeUInt = DefaultStackSize);
 begin
+  // Setup stack
   FStackSize := StackSize;
   FStack := GetMem(FStackSize);
-  FBasePointer := FStack + FStackSize;
+  FBasePointer := FStack + FStackSize - SizeOf(Pointer);
   FStackPointer := FBasePointer - SizeOf(Pointer);
+  FillChar(FStackPointer^, 2 * SizeOf(Pointer), 0);
+
   FExecutionTime := 0;
   FState := tsWaiting;
@@ -886 +892 @@
 
 procedure TMicroThread.Suspend;
+var
+  MT: TMicroThread;
 begin
   FStatePending := tsSuspended;
-  //Yield;
+  MT := GetCurrentMicroThread;
+  if Assigned(MT) then Yield;
 end;
 
@@ -918 +927 @@
 begin
   try
-    NewMicroThread := TMicroThreadSimple.Create(False);
+    NewMicroThread := TMicroThreadSimple.Create(True);
     NewMicroThread.Method := Method;
     NewMicroThread.FScheduler := Self;
     NewMicroThread.FreeOnTerminate := not WaitForFinish;
+    NewMicroThread.Start;
     if WaitForFinish then begin
       CurrentMT := GetCurrentMicroThread;
-      while not ((NewMicroThread.FState = tsBlocked) and
-      (NewMicroThread.FBlockState = tbsTerminated)) do begin
-        try
-          FMicroThreadsLock.Release;
-          if Assigned(CurrentMT) then CurrentMT.MTSleep(1 * OneMillisecond)
-          else begin
-            Sleep(1);
-            Application.ProcessMessages;
+      try
+        FMicroThreadsLock.Acquire;
+        while not ((NewMicroThread.FState = tsBlocked) and
+        (NewMicroThread.FBlockState = tbsTerminated)) do begin
+          try
+            FMicroThreadsLock.Release;
+            if Assigned(CurrentMT) then CurrentMT.MTSleep(1 * OneMillisecond)
+            else begin
+              Sleep(1);
+              Application.ProcessMessages;
+            end;
+          finally
+            FMicroThreadsLock.Acquire;
           end;
-        finally
-          FMicroThreadsLock.Acquire;
         end;
+      finally
+        FMicroThreadsLock.Release;
       end;
     end;