Issue #19112: avoid using function defined in method.
This commit is contained in:
parent
72a98541f0
commit
8b3f5aafd3
|
@ -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()
|
||||
|
||||
|
|
Loading…
Reference in New Issue