[*] Should not call DateTime.ToLocalTime inner PTP

Author: ZjzMisaka

PowerThreadPool/Core/PowerThreadPool.Events.cs

@@ -31,7 +31,7 @@ internal void InvokeWorkEndedEvent(ExecuteResultBase executeResult)
         {
             executeResult.EndDateTime = DateTime.UtcNow;
             Interlocked.Increment(ref _endCount);
-            Interlocked.Add(ref _executeTime, (long)(executeResult.EndDateTime - executeResult.StartDateTime).TotalMilliseconds);
+            Interlocked.Add(ref _executeTime, (long)(executeResult.UtcEndDateTime - executeResult.UtcStartDateTime).TotalMilliseconds);
             if (WorkEnded != null)
             {
                 WorkEndedEventArgs e = new WorkEndedEventArgs()
@@ -40,9 +40,9 @@ internal void InvokeWorkEndedEvent(ExecuteResultBase executeResult)
                     Exception = executeResult.Exception,
                     Result = executeResult.GetResult(),
                     Succeed = executeResult.Status == Status.Succeed,
-                    QueueDateTime = executeResult.QueueDateTime,
-                    StartDateTime = executeResult.StartDateTime,
-                    EndDateTime = executeResult.EndDateTime,
+                    QueueDateTime = executeResult.UtcQueueDateTime,
+                    StartDateTime = executeResult.UtcStartDateTime,
+                    EndDateTime = executeResult.UtcEndDateTime,
                     RetryInfo = executeResult.RetryInfo,
                 };
 
@@ -63,16 +63,16 @@ internal void InvokeWorkStoppedEvent(ExecuteResultBase executeResult)
         {
             executeResult.EndDateTime = DateTime.UtcNow;
             Interlocked.Increment(ref _endCount);
-            Interlocked.Add(ref _executeTime, (long)(executeResult.EndDateTime - executeResult.StartDateTime).TotalMilliseconds);
+            Interlocked.Add(ref _executeTime, (long)(executeResult.UtcEndDateTime - executeResult.UtcStartDateTime).TotalMilliseconds);
             if (WorkStopped != null)
             {
                 WorkStoppedEventArgs e = new WorkStoppedEventArgs()
                 {
                     ID = executeResult.ID,
                     ForceStop = executeResult.Status == Status.ForceStopped,
-                    QueueDateTime = executeResult.QueueDateTime,
-                    StartDateTime = executeResult.StartDateTime,
-                    EndDateTime = executeResult.EndDateTime,
+                    QueueDateTime = executeResult.UtcQueueDateTime,
+                    StartDateTime = executeResult.UtcStartDateTime,
+                    EndDateTime = executeResult.UtcEndDateTime,
                 };
                 SafeInvoke(WorkStopped, e, ErrorFrom.WorkStopped, executeResult);
             }
@@ -113,15 +113,15 @@ internal void InvokeWorkCanceledEvent(ExecuteResultBase executeResult)
         {
             executeResult.EndDateTime = DateTime.UtcNow;
             Interlocked.Increment(ref _endCount);
-            Interlocked.Add(ref _executeTime, (long)(executeResult.EndDateTime - executeResult.StartDateTime).TotalMilliseconds);
+            Interlocked.Add(ref _executeTime, (long)(executeResult.UtcEndDateTime - executeResult.UtcStartDateTime).TotalMilliseconds);
             if (WorkCanceled != null)
             {
                 WorkCanceledEventArgs e = new WorkCanceledEventArgs()
                 {
                     ID = executeResult.ID,
-                    QueueDateTime = executeResult.QueueDateTime,
-                    StartDateTime = executeResult.StartDateTime,
-                    EndDateTime = executeResult.EndDateTime,
+                    QueueDateTime = executeResult.UtcQueueDateTime,
+                    StartDateTime = executeResult.UtcStartDateTime,
+                    EndDateTime = executeResult.UtcEndDateTime,
                 };
                 SafeInvoke(WorkCanceled, e, ErrorFrom.WorkCanceled, executeResult);
             }

PowerThreadPool/EventArguments/ErrorOccurredEventArgs.cs

@@ -41,9 +41,9 @@ public ErrorOccurredEventArgs(Exception exception, ErrorFrom errorFrom, ExecuteR
             if (executeResult != null)
             {
                 ID = executeResult.ID;
-                QueueDateTime = executeResult.QueueDateTime;
-                StartDateTime = executeResult.StartDateTime;
-                EndDateTime = executeResult.EndDateTime;
+                QueueDateTime = executeResult.UtcQueueDateTime;
+                StartDateTime = executeResult.UtcStartDateTime;
+                EndDateTime = executeResult.UtcEndDateTime;
             }
             Exception = exception;
             ErrorFrom = errorFrom;

PowerThreadPool/EventArguments/WorkEventArgsBase.cs

@@ -11,19 +11,34 @@ public WorkEventArgsBase() { }
         /// </summary>
         public string ID { get; internal set; }
 
+        private DateTime _queueDateTime;
         /// <summary>
-        /// queue datetime.
+        /// Queue datetime.
         /// </summary>
-        public DateTime QueueDateTime { get; internal set; }
+        public DateTime QueueDateTime
+        {
+            get => _queueDateTime.ToLocalTime();
+            internal set => _queueDateTime = value;
+        }
 
+        private DateTime _startDateTime;
         /// <summary>
-        /// start datetime.
+        /// Start datetime.
         /// </summary>
-        public DateTime StartDateTime { get; internal set; }
+        public DateTime StartDateTime
+        {
+            get => _startDateTime.ToLocalTime();
+            internal set => _startDateTime = value;
+        }
 
+        private DateTime _endDateTime;
         /// <summary>
-        /// callback datetime.
+        /// End datetime.
         /// </summary>
-        public DateTime EndDateTime { get; internal set; }
+        public DateTime EndDateTime
+        {
+            get => _endDateTime.ToLocalTime();
+            internal set => _endDateTime = value;
+        }
     }
 }

PowerThreadPool/Results/ExecuteResult.cs

@@ -51,7 +51,7 @@ internal override ExecuteResult<TRes> ToTypedResult<TRes>()
                     Exception = Exception,
                     Result = (TRes)(object)Result,
                     ID = ID,
-                    QueueDateTime = QueueDateTime
+                    QueueDateTime = UtcQueueDateTime
                 };
             }
             return result;

PowerThreadPool/Results/ExecuteResultBase.cs

@@ -31,6 +31,7 @@ public DateTime QueueDateTime
             get => _queueDateTime.ToLocalTime();
             internal set => _queueDateTime = value;
         }
+        internal DateTime UtcQueueDateTime => _queueDateTime;
 
         private DateTime _startDateTime;
         /// <summary>
@@ -41,6 +42,7 @@ public DateTime StartDateTime
             get => _startDateTime.ToLocalTime();
             internal set => _startDateTime = value;
         }
+        internal DateTime UtcStartDateTime => _startDateTime;
 
         private DateTime _endDateTime;
         /// <summary>
@@ -51,6 +53,7 @@ public DateTime EndDateTime
             get => _endDateTime.ToLocalTime();
             internal set => _endDateTime = value;
         }
+        internal DateTime UtcEndDateTime => _endDateTime;
 
         /// <summary>
         /// Retry information.

PowerThreadPool/Works/WorkBase.cs

@@ -33,6 +33,9 @@ internal bool IsPausing
         internal bool ShouldStop { get; set; }
         internal bool DependencyFailed { get; set; }
         internal ManualResetEvent PauseSignal { get; set; }
+        /// <summary>
+        /// Queue datetime (UTC).
+        /// </summary>
         internal DateTime QueueDateTime { get; set; }
         internal abstract object Execute();
         internal abstract bool Stop(bool forceStop);