address comments

Signed-off-by: Qing Wang <kingchin1218@gmail.com>
ray-project · Jul 7, 2023 · 2ac04af · 2ac04af
1 parent 0b3980c
commit 2ac04af
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/fed/cleanup.py b/fed/cleanup.py
@@ -46,8 +46,6 @@ def __init__(self) -> None:
         self._sending_obj_refs_q = deque()
         self._check_send_thread = None
         self._monitor_thread = None
-        self._lock_on_sending_q = threading.Lock()
-        self._lock_on_send_thread = threading.Lock()
 
     def start(self, exit_when_failure_sending=False):
         self._exit_when_failure_sending = exit_when_failure_sending
@@ -91,7 +89,7 @@ def _signal_exit():
             try:
                 obj_ref = self._sending_obj_refs_q.popleft()
             except IndexError:
-                time.sleep(0.5)
+                time.sleep(0.1)
                 continue
             if isinstance(obj_ref, bool):
                 break