Function close_queue

Lib/test/_test_multiprocessing.py:100–103 · view source on GitHub ↗

(queue)

Source from the content-addressed store, hash-verified

98
99
100	def close_queue(queue):
101	if isinstance(queue, multiprocessing.queues.Queue):
102	queue.close()
103	queue.join_thread()
104
105
106	def join_process(process):

test_args_argumentMethod · 0.85

test_processMethod · 0.85

test_process_mainthread_native_idMethod · 0.85

test_closeMethod · 0.85

test_lose_target_refMethod · 0.85

test_child_fd_inflationMethod · 0.85

test_putMethod · 0.85

test_getMethod · 0.85

test_forkMethod · 0.85

test_qsizeMethod · 0.85

test_task_doneMethod · 0.85

test_timeoutMethod · 0.85

join_threadMethod · 0.80

closeMethod · 0.45

no test coverage detected

searching dependent graphs…