Недавно делал быстрый прототип асинхронного приложения в котором требовалось вызывать много синхронного кода. Да, я знаю, что это не лучший дизайн, но нужно было быстрое решение на один процесс и без очередей. Поэтому я выполнял код в потоках.
Выглядело это примерно так:
from fastapi.concurrency import run_in_threadpool
async def execute(data: DataRequest) -> DataResponse:
try:
result = await run_in_threadpool(sync_function, data)
return DataResponse(data=result)
except Exception as e:
return DataResponse(
error=str(e),
success=False,
)
В общем работает нормально. Для всех вызовов под капотом используется общий тредпул, всё работает предсказуемо.
Но потребовалось изменить количество запускаемых в пуле потоков (по умолчанию создается 40 воркеров).
Так как дело происходит с FastAPI, делается это через lifespan используя настройки anyio:
import anyio
@asynccontextmanager
async def lifespan(app: FastAPI):
limiter = anyio.to_thread.current_default_thread_limiter()
limiter.total_tokens = 100
yield
# если вдруг нужно вернуть обратно
limiter.total_tokens = 40
Зачем менять количество воркеров?
- уменьшить, если оперативки мало (один тред занимает ~8мб)
- увеличить чтобы выдержать нагрузку
Если есть предложения получше при тех же вводных - предлагайте😉
#async
#POWR/USDT analysis :
#POWR has successfully broken above the trendline and is anticipated to continue its upward movement, with the potential to test previous highs. This breakout signals a bullish trend, suggesting further price appreciation in the near term.
TF : 1D
Entry : $0.3090
Target : $0.4500
SL : $0.2270
#POWR/USDT analysis :
#POWR is currently in an uptrend, trading above the 200 EMA. The price has bounced back from the support zone with strong volume. As a result, we can expect the price to maintain its bullish momentum and test higher levels.
TF : 2H
Entry : $0.3500
Target : $0.4200
SL : $0.3022
#POWR/USDT analysis :
#POWR is in a correction phase and has recently tested the resistance zone near the 200 EMA. The price is anticipated to be rejected from there and continue its downward direction. Wait for the break of the $0.1936 level for entry.
TF : 4H
Entry : $0.1936
Target : $0.1751
SL : $0.2058
#POWR👈
https://www.binance.com/en/trade/POWR_BTC
Buy at current 320-335
Highly pumpable Coin on the brink of 🚀
Buy in parts 👈strictly follow for max profits as its pump coin
Sell
🤑360-380
🤑380-410
🤑 410-440
🤑 440-470
🚀 470- 500 & above
Bullish above -300
#POWR👈
https://www.binance.com/en/trade/POWR_BTC
Buy at current 485-495
Highly pumpable Coin on the brink of 🚀
Buy in parts 👈strictly follow for max profits as its pump coin
Sell
🤑520-550
🤑 550-600
🤑 600-650
🤑 650-700
🚀 700- 750 & above
Bullish above -470
#POWR👈
https://www.binance.com/en/trade/POWR_BTC
Buy at current 525-540
Highly pumpable Coin on the brink of 🚀
Buy in parts 👈strictly follow for max profits as its pump coin
Sell
🤑 570-600
🤑 600-650
🤑 650-700
🚀 700- 750 & above
Bullish above -510
#POWR👈
https://www.binance.com/en/trade/POWR_BTC
Buy at current 605-610
Highly pumpable Coin on the brink of 🚀
Buy in parts 👈strictly follow for max profits as its pump coin
Sell
🤑 640-670
🤑 670-730
🤑 730-790
🚀 790- 850 & above
Stop Loss/Exit -590