Method thread_read

tests/buffer/queue_test.py:80–85

(reader, result_queue)

        self.assertEqual(len(exps), self.put_batch_size * 2)

        def thread_read(reader, result_queue):
            try:
                batch = asyncio.run(reader.read())
                result_queue.put(batch)
            except StopAsyncIteration as e:
                result_queue.put(e)

        result_queue = queue.Queue()
        t = threading.Thread(target=thread_read, args=(reader, result_queue))