Python中的并发编程asyncio库入门使用

import asyncio
async def hello_world():
    print("Hello World!")
    await asyncio.sleep(1)
    print("Hello again!")
async def main():
    task = asyncio.ensure_future(hello_world())
    await task
asyncio.run(main())

import asyncio
async def task1():
    print("Task 1 started")
    await asyncio.sleep(2)
    print("Task 1 finished")
    return "Task 1 result"
async def task2():
    print("Task 2 started")
    await asyncio.sleep(1)
    print("Task 2 finished")
    return "Task 2 result"
async def main():
    results = await asyncio.gather(task1(), task2())
    print(results)
asyncio.run(main())

import asyncio
async def handle_client(reader, writer):
    data = await reader.read(100)
    message = data.decode()
    print(f"Received: {message}")
    response = "Hello, client!"
    writer.write(response.encode())
    await writer.drain()
    writer.close()
async def main():
    server = await asyncio.start_server(handle_client, "127.0.0.1", 8080)
    async with server:
        await server.serve_forever()
asyncio.run(main())

import asyncio
async def foo():
    print("Start foo")
    await asyncio.sleep(1)
    print("End foo")
async def bar():
    print("Start bar")
    await asyncio.sleep(2)
    print("End bar")
async def main():
    task1 = asyncio.create_task(foo())
    task2 = asyncio.create_task(bar())
    await asyncio.gather(task1, task2)
asyncio.run(main())