并发与异步高级专题
配套习题（22 题）
参考答案在文末关于asyncio.Lock和threading.Lock的区别，以下说法哪项是正确的？
关于Celery分布式任务队列的架构，以下哪项描述是正确的？
在Python中，多进程适合处理哪种类型的任务？
使用aiohttp进行异步HTTP请求时，以下哪种方式是最正确的？
关于Python协程，以下说法哪项是正确的？
关于异步生成器的定义和使用，以下说法哪项是正确的？
关于asyncio.create_task()和直接await的区别，以下说法哪项是正确的？
实现异步上下文管理器需要定义哪些方法？
以下关于异步生成器的说法，哪些是正确的？
使用aiofiles进行异步文件操作时，以下哪些是正确做法？
以下关于asyncio同步原语的说法，哪些是正确的？
使用Celery定义和调用任务时，以下哪些是正确的做法？
以下关于asyncio.gather()和asyncio.wait()的说法，哪些是正确的？
以下关于异步上下文管理器的说法，哪些是正确的？
以下关于Python asyncio事件循环的说法，哪些是正确的？
使用Python的multiprocessing.Pool时，以下哪些是正确的做法？
Python 协程有四种状态：（已创建未运行）、COROUTINE_RUNNING（正在执行）、COROUTINE_SUSPENDED（在 点暂停）、COROUTINE_CLOSED（已完成或取消）。使用 asyncio.inspect() 模块可以检查协程状态。协程执行完毕后必须调用 () 方法释放资源，否则会产生警告。协程对象被垃圾回收时会自动调用 __del__ 方法并输出 "coroutine was never awaited" 警告。
asyncio.Task对象有四种状态：（等待运行）、RUNNING（正在执行）、（已取消）、DONE（已完成）。取消任务使用task.cancel()方法，该方法设置Cancelled异常。取消后需要await task来确认取消并处理异常。检查任务是否完成使用task.done()方法，获取结果使用task.result()（未完成时调用会抛异常）。
Python多进程间通信主要使用multiprocessing.和multiprocessing.。Queue是多生产者多消费者的队列，使用put()和()方法传递数据。Pipe创建双向管道，返回两个Connection对象用于通信。对于共享内存，使用multiprocessing.Value和multiprocessing.Array，但需要配合multiprocessing.Lock保护共享数据避免竞争。
使用asyncio进行TCP网络编程，服务器端使用asyncio.start_server()创建服务器，回调函数接收两个参数：和，分别用于读取和写入数据。读取数据使用await reader.read(1024)或await reader.readline()，写入数据使用writer.write(data)后必须调用await writer.()确保数据发送完成。关闭连接使用writer.close()并await writer.wait_closed()。
asyncio.Semaphore用于限制同时访问资源的协程数量。初始化时指定value=表示最多5个协程同时持有锁。获取信号量使用await semaphore.()，释放使用semaphore.()。推荐使用async with semaphore:语法自动管理获取和释放。Semaphore内部维护一个计数器，每acquire一次计数减1，计数为0时新请求需等待其他协程释放。
Celery任务有四种主要状态：（等待执行）、STARTED（正在执行）、（成功完成）、（执行失败）。使用result.status获取状态，使用result.ready()检查是否完成。获取任务结果使用result.get()方法，该方法会阻塞直到任务完成或超时。
