Use daemon threads

fjetter · fjetter · commit 4d3b1fb17a36 · 2022-03-03T13:44:15.000+01:00
diff --git a/distributed/_concurrent_futures_thread.py b/distributed/_concurrent_futures_thread.py
@@ -227,6 +227,7 @@ def weakref_cb(_, q=self._work_queue):
                     self._initargs,
                 ),
             )
+            t.daemon = True
             t.start()
             self._threads.add(t)
             _threads_queues[t] = self._work_queue

Original file line number	Diff line number	Diff line change
`@@ -227,6 +227,7 @@ def weakref_cb(_, q=self._work_queue):`
`227`	`227`	`self._initargs,`
`228`	`228`	`),`
`229`	`229`	`)`
	`230`	`+ t.daemon = True`
`230`	`231`	`t.start()`
`231`	`232`	`self._threads.add(t)`
`232`	`233`	`_threads_queues[t] = self._work_queue`