@@ -99,7 +99,8 @@ def __init__(self, filename, queue_size=2, block_size=1024 * 1024):
99
99
self .buffer = io .BytesIO ()
100
100
self .block_size = block_size
101
101
# 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
103
104
self ._closed = False
104
105
self .running = True
105
106
self .worker .start ()
@@ -233,17 +234,19 @@ def __init__(self,
233
234
self .output_queues : List [queue .Queue [Tuple [bytes , int , int ]]] = [
234
235
queue .Queue (queue_size ) for _ in range (threads )]
235
236
# 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 : List [threading .Thread ] = []
240
+ for i in range (threads ):
241
+ worker = threading .Thread (target = self ._compress , args = (i ,))
242
+ worker .daemon = True
243
+
241
244
elif threads == 1 :
242
245
self .input_queues = [queue .Queue (queue_size )]
243
246
self .output_queues = []
244
247
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
247
250
else :
248
251
raise ValueError (f"threads should be at least 1, got { threads } " )
249
252
self .threads = threads
0 commit comments