diff --git a/src/core/Akka/Actor/Scheduler/HashedWheelTimerScheduler.cs b/src/core/Akka/Actor/Scheduler/HashedWheelTimerScheduler.cs index 45a6c0467f7..904866da65f 100644 --- a/src/core/Akka/Actor/Scheduler/HashedWheelTimerScheduler.cs +++ b/src/core/Akka/Actor/Scheduler/HashedWheelTimerScheduler.cs @@ -250,10 +250,10 @@ private void Start() if (_workerState == WORKER_STATE_STARTED) { } // do nothing else if (_workerState == WORKER_STATE_INIT) { + _worker = new Thread(Run) { IsBackground = true }; if (Interlocked.CompareExchange(ref _workerState, WORKER_STATE_STARTED, WORKER_STATE_INIT) == WORKER_STATE_INIT) { - _worker = new Thread(Run) { IsBackground = true }; _worker.Start(); } }