瀏覽代碼

Fix issue with timer starting after stop() is called. Now it doesn't start in this situation.

Ionel Cristian Mărieș 11 年之前
父節點
當前提交
c87b41158a
共有 1 個文件被更改,包括 1 次插入1 次删除
  1. 1 1
      celery/utils/timer2.py

+ 1 - 1
celery/utils/timer2.py

@@ -86,8 +86,8 @@ class Timer(threading.Thread):
             os._exit(1)
             os._exit(1)
 
 
     def stop(self):
     def stop(self):
+        self._is_shutdown.set()
         if self.running:
         if self.running:
-            self._is_shutdown.set()
             self._is_stopped.wait()
             self._is_stopped.wait()
             self.join(THREAD_TIMEOUT_MAX)
             self.join(THREAD_TIMEOUT_MAX)
             self.running = False
             self.running = False