Method _shutdown_thread

Lib/test/test_queue.py:361–364

(self, q, results, event_end, immediate)

                pass

    def _shutdown_thread(self, q, results, event_end, immediate):
        event_end.wait()
        q.shutdown(immediate)
        results.append(q.qsize() == 0)

    def _join_thread(self, q, barrier_start):
        # Wait for the barrier to be complete.