Function get_data_from_queue

tests/unittest/llmapi/test_llm_utils.py:79–81

()

            queue.put(i)

    async def get_data_from_queue():
        for i in range(10):
            print(f"get: {queue.get()}")

    thread = threading.Thread(target=put_data_to_queue)
    thread.start()