Skip to content

Commit 897360b

Browse files
committed
Do not set daemon via kwargs
1 parent c6329c2 commit 897360b

File tree

1 file changed

+11
-8
lines changed

1 file changed

+11
-8
lines changed

src/zlib_ng/gzip_ng_threaded.py

Lines changed: 11 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,8 @@ def __init__(self, filename, queue_size=2, block_size=1024 * 1024):
9999
self.buffer = io.BytesIO()
100100
self.block_size = block_size
101101
# Using a daemon thread prevents programs freezing on error.
102-
self.worker = threading.Thread(target=self._decompress, daemon=True)
102+
self.worker = threading.Thread(target=self._decompress)
103+
self.worker.daemon = True
103104
self._closed = False
104105
self.running = True
105106
self.worker.start()
@@ -233,17 +234,19 @@ def __init__(self,
233234
self.output_queues: List[queue.Queue[Tuple[bytes, int, int]]] = [
234235
queue.Queue(queue_size) for _ in range(threads)]
235236
# Using daemon threads prevents a program freezing on error.
236-
self.output_worker = threading.Thread(target=self._write, daemon=True)
237-
self.compression_workers = [
238-
threading.Thread(target=self._compress, args=(i,), daemon=True)
239-
for i in range(threads)
240-
]
237+
self.output_worker = threading.Thread(target=self._write)
238+
self.output_worker.daemon = True
239+
self.compression_workers = []
240+
for i in range(threads):
241+
worker = threading.Thread(target=self._compress, args=(i,))
242+
worker.daemon = True
243+
241244
elif threads == 1:
242245
self.input_queues = [queue.Queue(queue_size)]
243246
self.output_queues = []
244247
self.compression_workers = []
245-
self.output_worker = threading.Thread(
246-
target=self._compress_and_write, daemon=True)
248+
self.output_worker = threading.Thread(target=self._compress_and_write)
249+
self.output_worker.daemon = True
247250
else:
248251
raise ValueError(f"threads should be at least 1, got {threads}")
249252
self.threads = threads

0 commit comments

Comments
 (0)