Changeset 271 for Common

Timestamp:

Aug 30, 2011, 3:47:29 PM (13 years ago)

Author:

george

Message:

• Added: RunInThreadAsync procedure for not waiting for job to be finished.

File:

• Common/UThreading.pas (modified) (8 diffs)

Common/UThreading.pas

@@ -89 +89 @@
   TTermThread = class(TListedThread)
   private
+    FOnFinished: TNotifyEvent;
   public
     State: TTermThreadState;
@@ -94 +95 @@
     Method: TMethodCall;
     procedure Execute; override;
+    property OnFinished: TNotifyEvent read FOnFinished write FOnFinished;
   end;
 
@@ -109 +111 @@
 
 procedure RunInThread(Method: TMethodCall);
+procedure RunInThreadAsync(Method: TMethodCall; Callback: TNotifyEvent = nil);
 procedure Synchronize(Method: TMethodCall);
 
@@ -124 +127 @@
     Thread := TTermThread.Create(True);
     Thread.FreeOnTerminate := False;
+    Thread.Method := Method;
     Thread.Resume;
-    Thread.Method := Method;
     while (Thread.State = ttsRunning) or (Thread.State = ttsReady) do begin
       if MainThreadID = ThreadID then Application.ProcessMessages;
@@ -137 +140 @@
 end;
 
+procedure RunInThreadAsync(Method: TMethodCall; Callback: TNotifyEvent = nil);
+var
+  Thread: TTermThread;
+begin
+  try
+    Thread := TTermThread.Create(True);
+    Thread.FreeOnTerminate := True;
+    Thread.Method := Method;
+    Thread.OnFinished := CallBack;
+    Thread.Resume;
+    //if Thread.State = ttsExceptionOccured then
+    //  raise Exception.Create(Thread.ExceptionMessage);
+  finally
+  end;
+end;
+
 procedure Synchronize(Method: TMethodCall);
 var
@@ -151 +170 @@
 end;
 
-{ TVirtualThread }
-
 
 { TThreadList }
@@ -186 +203 @@
                                                                                                                                                                                                                                                                                                                                     end;
 
-{ TVirtualThread }
-
-
 { TListedThread }
 
@@ -324 +338 @@
     Method;
     State := ttsFinished;
+    if Assigned(FOnFinished) then
+      FOnFinished(Self);
   except
-    on E: Exception do
-      if Assigned(OnException) then begin
+    on E: Exception do begin
+      ExceptionMessage := E.Message;
+      State := ttsExceptionOccured;
+      if Assigned(OnException) then
         OnException(FThread, E);
-        ExceptionMessage := E.Message;
-        State := ttsExceptionOccured;
-      end;
+    end;
   end;
 end;