Dr. Nick

Results 3 comments of Dr. Nick

Replacing: ``` self._receive_thread = threading.Thread(target=self._receive, name=name) ``` with ``` self._receive_thread = multiprocessing.Process(target=self._receive, name=name) ``` does seem to solve the problem, but I'm not sure enough of the side-effects of that.

It's using fork. You can manually force it by changing the pool creation like so: ``` pool = Pool(2, context=multiprocessing.get_context('fork')) ``` As for the "proposed solution", I'm not proposing it...

@dataaug the issue is with `fork`, the `spawn` functionality has always worked. The root of the issue is, as @heiner0815 said, that you should not fork a multithreaded process. Doing...