Dec 15, 2024 · Dec 4, 2024 · Dec 4, 2024 · Dec 4, 2024 · Dec 10, 2024 · Dec 12, 2024
diff --git a/Lib/test/_test_multiprocessing.py b/Lib/test/_test_multiprocessing.py
                self._test_resource_tracker_leak_resources(
                    cleanup=cleanup,
                )

    def test_resource_tracker_blocked_signals(self):
        #
        # gh-127586: Check that resource_tracker does not override blocked signals of caller.
        #
        from multiprocessing.resource_tracker import ResourceTracker
        signals = {signal.SIGTERM, signal.SIGINT, signal.SIGUSR1}

        for sig in signals:
            signal.pthread_sigmask(signal.SIG_SETMASK, {sig})
            self.assertEqual(signal.pthread_sigmask(signal.SIG_BLOCK, set()), {sig})
            tracker = ResourceTracker()
            tracker.ensure_running()
            self.assertEqual(signal.pthread_sigmask(signal.SIG_BLOCK, set()), {sig})
            tracker._stop()

 class TestSimpleQueue(unittest.TestCase):
Original file line number	Diff line number	Diff line change
Expand Up		@@ -6044,6 +6044,21 @@ def test_resource_tracker_exit_code(self):
		self._test_resource_tracker_leak_resources(
		cleanup=cleanup,
		)

		def test_resource_tracker_blocked_signals(self):
		#
		# gh-127586: Check that resource_tracker does not override blocked signals of caller.
		#
		from multiprocessing.resource_tracker import ResourceTracker
		signals = {signal.SIGTERM, signal.SIGINT, signal.SIGUSR1}

		for sig in signals:
		signal.pthread_sigmask(signal.SIG_SETMASK, {sig})
		self.assertEqual(signal.pthread_sigmask(signal.SIG_BLOCK, set()), {sig})
		tracker = ResourceTracker()
		tracker.ensure_running()
		self.assertEqual(signal.pthread_sigmask(signal.SIG_BLOCK, set()), {sig})
		tracker._stop()

		class TestSimpleQueue(unittest.TestCase):

Expand Down