Отдельно разберём TaskGroup, который пришел на замену gather в Python 3.11.
Ключевые отличия
▫️create_task() возвращает объект asyncio.Task, у которого есть соответствюущие методы управления. То есть у нас больше контроля
▫️это контекстный менеджер, который гарантирует что все таски будут остановлены по выходу из контекста
▫️ошибка автоматически отменяет незавершенные задачи,
▫️except* передает нам ExceptionGroup, в котором каждую ошибку можно обработать отдельно
import asyncio
import random
async def do_it() -> str:
if random.random() < 0.1:
raise ValueError('Oops')
delay = random.uniform(0.5, 1.5)
await asyncio.sleep(delay)
return delay
async def main():
try:
async with asyncio.TaskGroup() as tg:
for _ in range(10):
tasks.append(tg.create_task(do_it()))
for t in tasks:
print(t.result())
except *ValueError as e:
for err in e.exceptions:
print(err)
asyncio.run(main())
Рекомендую изучить страницу Coroutines and Tasks из документации, где представлено больше интересных примеров и механизмов
- таймауты
- отмена задач
- создание задач из другого потока
#async
#RUNE/USDT analysis :
#RUNE has retested the resistance zone following a bullish impulsive move. The price is anticipated to bounce from the current level and test higher levels.
TF : 1W
Entry : $2.190
Target : $7.566
SL : $1.314
#RUNE/USDT analysis :
#RUNE has recently broken out of the 200 EMA with strong bullish momentum. The price is currently showing bullish price action. It is expected to rise higher. Before that, the price is expected to pull back and then rise higher. Wait for the price to test the support zone for a long entry.
TF : 2H
Entry : $3.813
Target : $4.233
SL : $3.603
#rune scalping opportunity 🧐
After the big dump, the previously formed liqudation void was closed. From here, it would either turn or dump would continue.
When we look at the short time frame, we see that it can start the rise by forming a failure swing.