Add test

Author: Drino

Lib/test/test_concurrent_futures/test_thread_pool.py

@@ -66,6 +66,25 @@ def submit(pool):
                 with futures.ProcessPoolExecutor(1, mp_context=mp.get_context('fork')) as workers:
                     workers.submit(tuple)
 
+    @support.requires_fork()
+    @unittest.skipUnless(hasattr(os, 'register_at_fork'), 'need os.register_at_fork')
+    @support.requires_resource('cpu')
+    def test_process_fork_from_a_threadpool(self):
+        # bpo-43944: clear concurrent.futures.thread._threads_queues after fork,
+        # otherwise child process will try to join parent thread
+        def fork_process_and_return_exitcode():
+            p = mp.get_context('fork').Process(target=lambda: 1)
+            p.start()
+            p.join()
+            return p.exitcode
+
+        with futures.ThreadPoolExecutor(1) as pool:
+            process_exitcode = pool.submit(fork_process_and_return_exitcode).result()
+        
+        self.assertEqual(process_exitcode, 0)
+
+
+
     def test_executor_map_current_future_cancel(self):
         stop_event = threading.Event()
         log = []