Cache immutable arrays in the Worker class

cezar-pimentel · Jun 20, 2024 · e1f9e12 · e1f9e12
1 parent 084d85b
commit e1f9e12
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/Hangfire.Core/Server/Worker.cs b/src/Hangfire.Core/Server/Worker.cs
@@ -46,6 +46,8 @@ public class Worker : IBackgroundProcess
         public static readonly string TransactionalAcknowledgePrefix = JobStorageFeatures.TransactionalAcknowledgePrefix;
 
         private static readonly ConcurrentDictionary<Guid, string> WorkerGuidCache = new();
+        private static readonly string[] EligibleWorkerStates = new[] { EnqueuedState.StateName, ScheduledState.StateName, ProcessingState.StateName };
+        private static readonly string[] ProcessingStateArray = new[] { ProcessingState.StateName };
 
         private readonly TimeSpan _jobInitializationWaitTimeout;
         private readonly int _maxStateChangeAttempts;
@@ -123,7 +125,7 @@ public void Execute(BackgroundProcessContext context)
                             fetchedJob.JobId, 
                             processingState, 
                             null,
-                            new[] { EnqueuedState.StateName, ScheduledState.StateName, ProcessingState.StateName },
+                            EligibleWorkerStates,
                             null,
                             out backgroundJob,
                             linkedCts.Token,
@@ -157,7 +159,7 @@ public void Execute(BackgroundProcessContext context)
                             fetchedJob.JobId,
                             state,
                             customData,
-                            new[] { ProcessingState.StateName },
+                            ProcessingStateArray,
                             transactionalAck ? fetchedJob : null,
                             out _,
                             CancellationToken.None,