Почему threading.Condition.notfiy_all не вызывает продолжение ожидающего потока? ⇐ Python

[Гость]

С помощью следующего кода я хочу показать, как синхронизироваться с потоком.

• Я хочу иметь отдельный поток, обновляющий изображение.< /li>
  Из этих изображений я хочу получить асинхронный генератор.
• Изображения следует обновлять только тогда, когда их использует асинхронный генератор.
• Асинхронный генератор должен ожидать создания нового изображения.

Ниже вы найдете код для этого. Он зависает в ожидании первого изображения.
Почему notify_all не выпускает image_created.wait?
# Output
create new image
waiting for new image
start waiter
notify_all
wait for someone to take it
waiting for image_created

import asyncio
import random
import threading
import time

class ImageUpdater:
def __init__(self):
self.image = None
self.image_used = threading.Event()
self.image_created = threading.Condition()

def update_image(self):
while True:
self.image_used.clear()
with self.image_created:
print("create new image")
time.sleep(0.6)
self.image = str(random.random())
print("notify_all")
self.image_created.notify_all()
print("wait for someone to take it")
self.image_used.wait()
print("someone took it")

async def image_generator(self):
def waiter():
print("start waiter")
time.sleep(0.1)
with self.image_created:
print("waiting for image_created")
self.image_created.wait()
print("waiter finished")
self.image_used.set()

while True:
print("waiting for new image")
await asyncio.to_thread(waiter)

yield self.image

async def main():
updater = ImageUpdater()

update_thread = threading.Thread(target=updater.update_image)
update_thread.start()

async for image in updater.image_generator():
print(f"Received new image: {image}")

if __name__ == "__main__":
loop = asyncio.run(main())



Подробнее здесь: https://stackoverflow.com/questions/781 ... d-is-conti