Changeset 160 for MicroThreading/UMicroThreading.pas

Timestamp:

Feb 1, 2011, 10:06:01 AM (14 years ago)

Author:

george

Message:

• Added: Unit UThreadEx which introduce class TThreadEx with support for method CurrentThread. Unit automatic mantain runtime thread list.
• Added: Testing of exceptions raised inside microthread in demo application.

Location:

MicroThreading

Files:

• . (modified) (1 prop)
• UMicroThreading.pas (modified) (15 diffs)

MicroThreading

@@ -1 +1 @@
 lib
+backup

@@ -1 +1 @@
 lib
+backup

MicroThreading/UMicroThreading.pas

@@ -19 +19 @@
   {$ENDIF}{$ENDIF}
   Classes, ExtCtrls, SysUtils, Contnrs, SyncObjs, DateUtils, Dialogs, Forms,
-  UPlatform, UMicroThreadList;
+  UPlatform, UMicroThreadList, UThreadEx;
 
 const
-  DefaultStackSize = $40000;
+  DefaultStackSize = $4000;
+
+resourcestring
+  SStackOverflow = 'Microthread %d stack error. Pointer %s , range < %s ; %s >';
+  SNilThreadReference = 'Can''t release nil thread.';
+  SManagerMicroThreadRunning = 'Manager already have running microthread';
 
 type
@@ -124 +129 @@
   { TMicroThreadThread }
 
-  TMicroThreadThread = class(TThread)
+  TMicroThreadThread = class(TThreadEx)
     Manager: TMicroThreadManager;
     State: TMicroThreadThreadState;
@@ -171 +176 @@
     FRoundRobinIndex: Integer;
     FLastId: Integer;
-    FFrequency: Int64;
     FMainThreadTerminated: Boolean;
     FMicroThreads: TObjectList; // TList<TMicroThread>
@@ -196 +200 @@
     function Add(MicroThread: TMicroThread): Integer;
     function AddMethod(Method: TMicroThreadMethod): Integer;
-    function FindCurrentThread: TThread;
     procedure Remove(MicroThread: TMicroThread; Free: Boolean = True);
     constructor Create;
@@ -217 +220 @@
   public
     Form: TMicroThreadListForm;
-    constructor Create(AOwner: TComponent);
+    constructor Create(AOwner: TComponent); override;
   end;
 
@@ -258 +261 @@
 function GetMicroThreadId: Integer;
 var
-  I: Integer;
-  CurrentStack: Pointer;
-begin
-  asm
-    mov CurrentStack, sp
-  end;
-  with MainScheduler do begin
-    try
-      FMicroThreadsLock.Acquire;
-      I := 0;
-      while (I < FMicroThreads.Count) and
-        not ((CurrentStack >= TMicroThread(FMicroThreads[I]).FStack) and
-        (CurrentStack <= (TMicroThread(FMicroThreads[I]).FStack +
-        TMicroThread(FMicroThreads[I]).FStackSize))) do Inc(I);
-      if I < FMicroThreads.Count then begin
-        Result := TMicroThread(FMicroThreads[I]).FId;
-      end else Result := -1;
-    finally
-      FMicroThreadsLock.Release;
-    end;
-  end;
+  MT: TMicroThread;
+begin
+  MT := GetCurrentMicroThread;
+  if Assigned(MT) then Result := MT.Id else Result := -1;
 end;
 
 function GetCurrentMicroThread: TMicroThread;
 var
-  I: Integer;
+  Thread: TThread;
 begin
   with MainScheduler do
@@ -289 +275 @@
     FMicroThreadsLock.Acquire;
     if MainThreadID = ThreadID then Result := MainThreadManager.CurrentMicroThread
-      else Result := TMicroThreadThread(MainScheduler.FindCurrentThread).Manager.CurrentMicroThread;
+      else begin
+        Thread := TThreadEx.CurrentThread;
+        if Assigned(Thread) then
+          Result := TMicroThreadThread(Thread).Manager.CurrentMicroThread
+          else Result := nil;
+      end;
   finally
     FMicroThreadsLock.Release;
@@ -309 +300 @@
 begin
   if GetCurrentThreadId <> MainThreadID then begin
-    Thread := MainScheduler.FindCurrentThread;
+    Thread := TThreadEx.CurrentThread;
     if Assigned(Thread) then TThread.Synchronize(Thread, Method)
       else raise Exception.Create('Can''t determine thread for id ' + IntToStr(GetCurrentThreadId));
@@ -483 +474 @@
           // but virtual methods can be called only statically
           // Then static method CallExecute is calling virtual method Execute
-            call TMicroThread.CallExecute
+          call TMicroThread.CallExecute
 
           // Restore manager stack
@@ -555 +546 @@
   ExecutedCount: Integer;
 begin
-  inherited Execute;
   try
     repeat
@@ -599 +589 @@
   except
     on E: Exception do
-      ExceptionHandler(Self, E);
+      if Assigned(ExceptionHandler) then ExceptionHandler(Self, E);
   end;
   asm
@@ -632 +622 @@
 begin
   if not ((FStackPointer > FStack) and (FStackPointer < (FStack + FStackSize)))
-    then raise EStackOverflow.Create(Format('Microthread %d stack error', [FId]));
+    then raise EStackOverflow.Create(Format(SStackOverflow,
+      [FId, IntToHex(Integer(FStackPointer), 8), IntToHex(Integer(FStack), 8),
+      IntToHex(Integer(FStack + FStackSize), 8)]));
 end;
 
@@ -766 +758 @@
   NewMicroThread.FScheduler := Self;
   Result := Add(NewMicroThread);
-end;
-
-function TMicroThreadScheduler.FindCurrentThread: TThread;
-var
-  I: Integer;
-begin
-  try
-    FThreadPoolLock.Acquire;
-    I := 0;
-    while (I < FThreadPool.Count) and (TMicroThreadThread(FThreadPool[I]).ThreadID <> ThreadID) do Inc(I);
-    if I < FThreadPool.Count then Result := TMicroThreadThread(FThreadPool[I])
-      else Result := nil;
-  finally
-    FThreadPoolLock.Release;
-  end;
 end;
 
@@ -951 +928 @@
     if I < FMicroThreads.Count then begin
       if Assigned(Manager.FCurrentMicroThread) then
-        raise Exception.Create('Manager have already have running microthread');
+        raise Exception.Create(SManagerMicroThreadRunning);
       Selected := TMicroThread(FMicroThreads[FRoundRobinIndex]);
       Selected.FState := tsRunning;
@@ -965 +942 @@
 begin
   if not Assigned(MicroThread) then
-    raise Exception.Create('Can''t release nil thread.');
+    raise Exception.Create(SNilThreadReference);
   try
     FMicroThreadsLock.Acquire;

@@ -1 +1 @@
 lib
+backup