Python异步编程实战

import asyncio

async def fetch_data(url):
    reader, writer = await asyncio.open_connection(url, 80)
    writer.write(b'GET / HTTP/1.1\r\nHost: example.com\r\n\r\n')
    data = await reader.read(1000)
    return data.decode()

def handle_exception(loop, context):
    logger.error(f"Unhandled exception: {context}")

loop = asyncio.get_event_loop()
loop.set_exception_handler(handle_exception)

async def worker(queue):
    while True:
        task = await queue.get()
        await process_task(task)
        queue.task_done()