This avoids messages like:
ThreadSanitizer: starting new threads after multi-threaded fork is not
supported. Dying (set die_after_fork=0 to override)
(cherry picked from commit
82a4dac9f6131954c32dac9d0277283fc5b499a9)
Co-authored-by: Sam Gross <colesbury@gmail.com>
)
manager.assert_not_called()
+ @skip_if_tsan_fork
@support.requires_subprocess()
def test_multiprocessing_queues(self):
# See gh-119819
import multiprocessing
from unittest.mock import patch
+ @skip_if_tsan_fork
@threading_helper.requires_working_threading()
class QueueListenerTest(BaseTest):
"""
else:
return results
+ @skip_if_tsan_fork
def test_multiprocessing(self):
support.skip_if_broken_multiprocessing_synchronize()
multiprocessing_imported = 'multiprocessing' in sys.modules