Check if sys.finalizing works

pycompression · Sep 23, 2024 · e8c9498 · e8c9498
1 parent 7f636c8
commit e8c9498
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/zlib_ng/gzip_ng_threaded.py b/src/zlib_ng/gzip_ng_threaded.py
@@ -11,6 +11,7 @@
 import os
 import queue
 import struct
+import sys
 import threading
 from typing import List, Optional, Tuple
 
@@ -124,7 +125,8 @@ def _decompress(self):
                     block_queue.put(data, timeout=0.05)
                     break
                 except queue.Full:
-                    pass
+                    if sys.is_finalizing():
+                        return
 
     def readinto(self, b):
         self._check_closed()