Changeset 153 for MicroThreading/UMicroThreading.pas

Timestamp:

Jan 27, 2011, 10:56:06 AM (14 years ago)

Author:

george

Message:

• Added: Synchronize method.

File:

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

MicroThreading/UMicroThreading.pas

@@ -69 +69 @@
     procedure Resume;
     procedure Suspend;
+    procedure Synchronize(AMethod: TThreadMethod);
 
     constructor Create(CreateSuspended: Boolean;
@@ -118 +119 @@
     FCurrentMicroThread: TMicroThread;
     FScheduler: TMicroThreadScheduler;
+    FThread: TMicroThreadThread;
     function Execute(Count: Integer): Integer;
   public
     Id: Integer;
     procedure Yield;
+    procedure Synchronize(AMethod: TThreadMethod);
     constructor Create;
     destructor Destroy; override;
@@ -332 +335 @@
 end;
 
+procedure TMicroThreadManager.Synchronize(AMethod: TThreadMethod);
+begin
+  if Assigned(FThread) then
+    FThread.Synchronize(FThread, AMethod);
+end;
+
 constructor TMicroThreadManager.Create;
 begin
   FCurrentMicroThread := nil;
+  FThread := nil;
 end;
 
@@ -487 +497 @@
   FSuspended := True;
   //Yield;
+end;
+
+procedure TMicroThread.Synchronize(AMethod: TThreadMethod);
+begin
+  FManager.Synchronize(AMethod);
 end;
 
@@ -538 +553 @@
   FMainThreadManager.Free;
   FThreadPool.Free;
+  FThreadPoolLock.Free;
   FMicroThreads.Free;
   FMicroThreadsLock.Free;
@@ -548 +564 @@
   UpdateThreadPoolSize;
   FState := ssRunning;
+  if FUseMainThread then
+    FMainThreadStarter.Enabled := True;
 end;
 
@@ -599 +617 @@
         NewThread := TMicroThreadThread.Create(True);
         NewThread.Manager.FScheduler := Self;
-        NewThread.Manager.Id := FThreadPool.Count;
+        NewThread.Manager.Id := FThreadPool.Count + 1;
+        NewThread.Manager.FThread := NewThread;
         NewThread.OnTerminate := PoolThreadTerminated;
         ThreadPool.Add(NewThread);