Don't leave threads running

This commit is contained in:
Andras Schmelczer 2022-07-02 00:13:25 +02:00
parent 61cd06c52f
commit 1d29bbfe56
No known key found for this signature in database
GPG key ID: 0EA1BC97D0AB076E

View file

@ -81,6 +81,7 @@ def threaded_parallel_map(
threading.Thread( threading.Thread(
name=f"threaded_parallel_map_{config.function_name}_{i}", name=f"threaded_parallel_map_{config.function_name}_{i}",
target=mapper_function, target=mapper_function,
daemon=True,
kwargs=dict( kwargs=dict(
input_queue=input_queue, input_queue=input_queue,
output_queue=output_queue, output_queue=output_queue,