]> granicus.if.org Git - python/commitdiff
Issue #19112: avoid using function defined in method.
authorRichard Oudkerk <shibturn@gmail.com>
Sun, 29 Sep 2013 16:29:56 +0000 (17:29 +0100)
committerRichard Oudkerk <shibturn@gmail.com>
Sun, 29 Sep 2013 16:29:56 +0000 (17:29 +0100)
Lib/test/test_multiprocessing.py

index a19bca0929c0fdf86ba1e83bef2a0941a43c48fc..6d20782a1585315862cbffa9aed5e63b9b7894c8 100644 (file)
@@ -3117,12 +3117,19 @@ class TestInitializers(unittest.TestCase):
 # Verifies os.close(sys.stdin.fileno) vs. sys.stdin.close() behavior
 #
 
-def _ThisSubProcess(q):
+def _this_sub_process(q):
     try:
         item = q.get(block=False)
     except pyqueue.Empty:
         pass
 
+def _test_process(q):
+    queue = multiprocessing.Queue()
+    subProc = multiprocessing.Process(target=_this_sub_process, args=(queue,))
+    subProc.daemon = True
+    subProc.start()
+    subProc.join()
+
 def _afunc(x):
     return x*x
 
@@ -3156,14 +3163,8 @@ class _file_like(object):
 class TestStdinBadfiledescriptor(unittest.TestCase):
 
     def test_queue_in_process(self):
-        def _TestProcess(q):
-            queue = multiprocessing.Queue()
-            subProc = multiprocessing.Process(target=_ThisSubProcess, args=(queue,))
-            subProc.daemon = True
-            subProc.start()
-            subProc.join()
         queue = multiprocessing.Queue()
-        proc = multiprocessing.Process(target=_TestProcess, args=(queue,))
+        proc = multiprocessing.Process(target=_test_process, args=(queue,))
         proc.start()
         proc.join()