Changeset 135 for Microthreading/umicrothreading.pas

Timestamp:

Jan 23, 2011, 8:04:49 PM (14 years ago)

Author:

george

Message:

• Added: Showing MicroThread list.
• Added: Measuring execution time.
• Added: Do not free micro thread on finish flag.

File:

• Microthreading/umicrothreading.pas (modified) (12 diffs)

Microthreading/umicrothreading.pas

@@ -7 +7 @@
 
 uses
-  Classes, SysUtils, Contnrs, SyncObjs;
+  Classes, SysUtils, Contnrs, SyncObjs, DateUtils,
+  BaseUnix, UnixUtil, Unix;
 
 type
@@ -21 +22 @@
   end;
 
-  TMicroThreadState = (tsReady, tsRunning, tsSleeping, tsBlocked, tsSuspended);
+  TMicroThreadState = (tsReady, tsRunning, tsWaiting, tsBlocked, tsSuspended,
+    tsSleeping, tsFinished);
 
   { TMicroThread }
@@ -32 +34 @@
     FExecutionStartTime: TDateTime;
     FExecutionEndTime: TDateTime;
+    FExecutionTime: TDateTime;
     FStackPointer: Pointer;
     FBasePointer: Pointer;
@@ -46 +49 @@
     destructor Destroy; override;
     property Method: TStartEvent read FMethod write FMethod;
+    property ExecutionTime: TDateTime read FExecutionTime;
   end;
 
@@ -56 +60 @@
   TMicroThreadScheduler = class
   private
+    FFreeMicroThreadOnFinish: Boolean;
     ThreadPool: TThreadPool;
-    MicroThreads: TObjectList; // TList<TMicroThread>
-    Lock: TCriticalSection;
     RoundRobinIndex: Integer;
     LastId: Integer;
@@ -65 +68 @@
     FSelected: TMicroThread;
     FTempPointer: Pointer;
+    function GetMicroThreadCount: Integer;
     procedure Yield(MicroThread: TMicroThread);
   public
+    MicroThreads: TObjectList; // TList<TMicroThread>
+    Lock: TCriticalSection;
     function Add(Name: string; Method: TStartEvent): TMicroThread;
     constructor Create;
     destructor Destroy; override;
     procedure Start;
-  end;
+    property MicroThreadCount: Integer read GetMicroThreadCount;
+    property FreeMicroThreadOnFinish: Boolean read FFreeMicroThreadOnFinish
+      write FFreeMicroThreadOnFinish;
+  end;
+
+const
+  MicroThreadStateText: array[TMicroThreadState] of string = ('Ready', 'Running',
+    'Waiting', 'Blocked', 'Suspended', 'Sleeping', 'Finished');
 
 implementation
 
+
+function SystemTicks: Int64;
+{$IFDEF Windows}
+begin
+  QueryPerformanceCounter(Result);
+  //Result := Int64(TimeStampToMSecs(DateTimeToTimeStamp(Now)) * 1000) // an alternative Win32 timebase
+{$ELSE}
+var t : timeval;
+begin
+  fpgettimeofday(@t,nil);
+   // Build a 64 bit microsecond tick from the seconds and microsecond longints
+  Result := (Int64(t.tv_sec) * 1000000) + t.tv_usec;
+{$ENDIF}
+end;
+
+
 { TMicroThread }
 
@@ -84 +113 @@
 procedure TMicroThread.Sleep(Duration: TDateTime);
 begin
-  FWakeupTime := Now + Duration;
-  State := tsBlocked;
+  FWakeUpTime := Now + Duration;
+  State := tsSleeping;
   Yield;
 end;
@@ -124 +153 @@
   MicroThreads := TObjectList.Create;
   ThreadPool := TThreadPool.Create;
+  FFreeMicroThreadOnFinish := True;
 end;
 
@@ -149 +179 @@
 begin
   if Assigned(MicroThread) then begin
-    MicroThread.FExecutionStartTime := Now;
-    MicroThread.State := tsSleeping;
+    MicroThread.FExecutionEndTime := Now;
+    MicroThread.FExecutionTime := MicroThread.FExecutionTime +
+      (MicroThread.FExecutionEndTime - MicroThread.FExecutionStartTime);
+    if MicroThread.State = tsRunning then
+      MicroThread.State := tsWaiting;
     asm
       // Store microthread stack
@@ -179 +212 @@
       RoundRobinIndex := 0;
     while (I < MicroThreads.Count) and (TMicroThread(MicroThreads[RoundRobinIndex]).State <> tsReady) and
-(TMicroThread(MicroThreads[RoundRobinIndex]).State <> tsSleeping) do begin
-      Inc(I);
-      Inc(RoundRobinIndex);
-      if RoundRobinIndex >= MicroThreads.Count then
-        RoundRobinIndex := 0;
+(TMicroThread(MicroThreads[RoundRobinIndex]).State <> tsWaiting) do begin
+      // WakeUp sleeping threads
+      if (TMicroThread(MicroThreads[RoundRobinIndex]).State = tsSleeping) and
+        (TMicroThread(MicroThreads[RoundRobinIndex]).FWakeupTime < Now) then
+          TMicroThread(MicroThreads[RoundRobinIndex]).State := tsWaiting else
+      begin
+        // Go to next thread
+        Inc(I);
+        Inc(RoundRobinIndex);
+        if RoundRobinIndex >= MicroThreads.Count then
+          RoundRobinIndex := 0;
+      end;
     end;
     if I < MicroThreads.Count then begin
@@ -229 +269 @@
         mov ebp, edx
       end;
-      // Microthread is finished, remove it from queue
-      try
-        Lock.Acquire;
-        MicroThreads.Delete(MicroThreads.IndexOf(FSelected));
-      finally
-        Lock.Release;
-      end;
+      if FFreeMicroThreadOnFinish then begin
+        // Microthread is finished, remove it from queue
+        try
+          Lock.Acquire;
+          MicroThreads.Delete(MicroThreads.IndexOf(FSelected));
+        finally
+          Lock.Release;
+        end;
+      end else FSelected.State := tsFinished;
     end else
-    if FSelected.State = tsSleeping then begin
+    if FSelected.State = tsWaiting then begin
       // Execute selected thread
       FSelected.State := tsRunning;
@@ -258 +300 @@
 end;
 
+function TMicroThreadScheduler.GetMicroThreadCount: Integer;
+begin
+  try
+    Lock.Acquire;
+    Result := MicroThreads.Count;
+  finally
+    Lock.Release;
+  end;
+end;
+
 end.