Function close_queue

Lib/test/_test_multiprocessing.py:98–101 · view source on GitHub ↗

(queue)

Source from the content-addressed store, hash-verified

96
97
98	def close_queue(queue):
99	if isinstance(queue, multiprocessing.queues.Queue):
100	queue.close()
101	queue.join_thread()
102
103
104	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

isinstanceFunction · 0.85

join_threadMethod · 0.80

closeMethod · 0.45

no test coverage detected