同步原语

asyncio 同步原语被设计为与模块的类似，但有两个关键注意事项:

asyncio 具有下列基本同步原语:

class asyncio.Lock(**, loop=None*)

实现一个用于 asyncio 任务的互斥锁。非线程安全。

asyncio 锁可被用来保证对共享资源的独占访问。

使用 Lock 的推荐方式是通过 async with 语句:

这等价于:

lock = asyncio.Lock()
# ... later
try:
    # access shared state
finally:
    lock.release()

Deprecated since version 3.8, will be removed in version 3.10: loop 形参。

class asyncio.Event(**, loop=None*)

事件对象。该对象不是线程安全的。

asyncio 事件可被用来通知多个 asyncio 任务已经有事件发生。

Event 对象会管理一个内部旗标，可通过方法将其设为 true 并通过 clear() 方法将其重设为 false。方法会阻塞直至该旗标被设为 true。该旗标初始时会被设为 false。

示例:

class asyncio.Condition(lock=None, **, loop=None*)

条件对象。该对象不是线程安全的。

asyncio 条件原语可被任务用于等待某个事件发生，然后获取对共享资源的独占访问。

在本质上，Condition 对象合并了和 Lock 的功能。多个 Condition 对象有可能共享一个 Lock，这允许关注于共享资源的特定状态的不同任务实现对共享资源的协同独占访问。

可选的 lock 参数必须为对象或 None。在后一种情况下会自动创建一个新的 Lock 对象。

Deprecated since version 3.8, will be removed in version 3.10: loop 形参。

使用 Condition 的推荐方式是通过 async with 语句:

cond = asyncio.Condition()
# ... later
async with cond:

这等价于:

coroutine acquire()

获取下层的锁。

此方法会等待直至下层的锁为 unlocked，将其设为 locked 并返回 returns True。
notify(n=1)

唤醒最多 n 个正在等待此条件的任务（默认为 1 个）。如果没有任务正在等待则此方法为空操作。

锁必须在此方法被调用前被获取并在随后被快速释放。如果通过一个 unlocked 锁调用则会引发。
locked()

如果下层的锁已被获取则返回 True。
notify_all()

唤醒所有正在等待此条件的任务。

锁必须在此方法被调用前被获取并在随后被快速释放。如果通过一个 unlocked 锁调用则会引发 RuntimeError。
release()

释放下层的锁。

当在未锁定的锁上发起调用时，会引发。
coroutine wait()

等待直至收到通知。

当此方法被调用时如果调用方任务未获得锁，则会引发 RuntimeError。

这个方法会释放下层的锁，然后保持阻塞直到被或 notify_all() 调用所唤醒。一旦被唤醒，Condition 会重新获取它的锁并且此方法将返回 True。
coroutine wait_for(predicate)

等待直到目标值变为 true。

目标必须为一个可调用对象，其结果将被解读为一个布尔值。最终的值将为返回值。

class (value=1, **, loop=None*)

信号量对象。该对象不是线程安全的。

信号量会管理一个内部计数器，该计数器会随每次调用递减并随每次 release() 调用递增。计数器的值永远不会降到零以下；当发现其值为零时，它将保持阻塞直到有某个任务调用了 release()。

可选的 value 参数用来为内部计数器赋初始值 (默认值为 1)。如果给定的值小于 0 则会引发。

Deprecated since version 3.8, will be removed in version 3.10: loop 形参。

使用 Semaphore 的推荐方式是通过 async with 语句。:

sem = asyncio.Semaphore(10)
# ... later
async with sem:
    # work with shared resource

这等价于:

coroutine acquire()

获取一个信号量。

如果内部计数器的值大于零，则将其减一并立即返回 True。如果其值为零，则会等待直到并调用并返回 True。
locked()

如果信号量对象无法被立即获取则返回 True。
release()

释放一个信号量对象，将内部计数器的值加一。可以唤醒一个正在等待获取信号量对象的任务。

不同于 BoundedSemaphore，允许执行的 release() 调用多于 acquire() 调用。

class asyncio.BoundedSemaphore(value=1, **, loop=None*)

绑定的信号量对象。该对象不是线程安全的。

BoundedSemaphore 是特殊版本的 Semaphore，如果在中内部计数器值增加到初始 value 以上它将引发一个 ValueError。

Deprecated since version 3.8, will be removed in version 3.10: loop 形参。