You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Что сделать:
В RabbitMessageBroker.consume добавить аргумент parallel: bool = Fasle, который определит вариант вызова callback-а.
Для I/O задач parallel=True — running_loop.create_task(callback(message))
Для CPU и Memory задач parallel=False — await callback(message)
Зачем сделать:
Для тяжёлых CPU, а особенно Memory, задач одновременное загрузка их в event loop в виде Task-ов может перегрузить компьютер, поэтому их стоит грузить в event loop по одной. Получится нечто вроде синхронной обработки, но при этом не нужно будет писать отдельный, синхронный, консьюмер на основе pika.
The text was updated successfully, but these errors were encountered:
Что сделать:
В
RabbitMessageBroker.consume
добавить аргументparallel: bool = Fasle
, который определит вариант вызова callback-а.parallel=True
—running_loop.create_task(callback(message))
parallel=False
—await callback(message)
Зачем сделать:
Для тяжёлых CPU, а особенно Memory, задач одновременное загрузка их в event loop в виде Task-ов может перегрузить компьютер, поэтому их стоит грузить в event loop по одной. Получится нечто вроде синхронной обработки, но при этом не нужно будет писать отдельный, синхронный, консьюмер на основе
pika
.The text was updated successfully, but these errors were encountered: