Queue is already threadsafe.

Refs #2874
coleifer · Apr 19, 2024 · 7dcaf9c · 7dcaf9c
1 parent e6483e2
commit 7dcaf9c
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/playhouse/sqliteq.py b/playhouse/sqliteq.py
@@ -286,12 +286,10 @@ def is_stopped(self):
             return self._is_stopped
 
     def pause(self):
-        with self._qlock:
-            self._write_queue.put(PAUSE)
+        self._write_queue.put(PAUSE)
 
     def unpause(self):
-        with self._qlock:
-            self._write_queue.put(UNPAUSE)
+        self._write_queue.put(UNPAUSE)
 
     def __unsupported__(self, *args, **kwargs):
         raise ValueError('This method is not supported by %r.' % type(self))