Ensure we are not shutting down when pausing or unpausing.

Refs #2877
coleifer · Apr 26, 2024 · 68fb127 · 68fb127
1 parent 519a84e
commit 68fb127
Showing 1 changed file with 14 additions and 4 deletions.
diff --git a/playhouse/sqliteq.py b/playhouse/sqliteq.py
@@ -301,13 +301,23 @@ def is_stopped(self):
             return self._is_stopped
 
     def pause(self):
-        evt = self._thread_helper.event()
-        self._write_queue.put((PAUSE, evt))
+        with self._qlock:
+            if self._is_stopped:
+                return False
+
+            evt = self._thread_helper.event()
+            self._write_queue.put((PAUSE, evt))
+
         evt.wait()
 
     def unpause(self):
-        evt = self._thread_helper.event()
-        self._write_queue.put((UNPAUSE, evt))
+        with self._qlock:
+            if self._is_stopped:
+                return False
+
+            evt = self._thread_helper.event()
+            self._write_queue.put((UNPAUSE, evt))
+
         evt.wait()
 
     def __unsupported__(self, *args, **kwargs):