Недавно делал быстрый прототип асинхронного приложения в котором требовалось вызывать много синхронного кода. Да, я знаю, что это не лучший дизайн, но нужно было быстрое решение на один процесс и без очередей. Поэтому я выполнял код в потоках.
Выглядело это примерно так:
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
#ONE/USDT analysis :
#ONE has broken out of the trendline following a bounce from the support zone, accompanied by a strong volume candle. The price is expected to continue its bullish momentum soon and test the previous highs. A potential gain of +1100% is anticipated from the current level.
TF : 1M
Entry : $0.03000
Target : $0.37897
SL : $0.02100
#ONE/USDT analysis :
#ONE is currently forming a structure of higher highs (HHs) and higher lows (HLs) above the 200 EMA. The price is anticipated to sustain its momentum and reach new highs. Wait for a pullback to enter long positions.
TF : 1H
Entry : $0.0113
Target : $0.0122
SL : $0.0108
#ONE/USDT analysis :
#ONE is currently consolidating sideways within the support and resistance zone. At the moment, the price is bouncing off the support zone and is expected to test the resistance zone.
TF : 4H
Entry : $0.0104
Target : $0.0110
SL : $0.0100
#ONE/USDT analysis -
#ONE is in a downtrend making lower lows (LLs) and lower highs (LHs). The price is currently facing resistance and is expected to be rejected from there, continuing its bearish momentum to test previous lows.
TF : 4h
Entry : $0.0150
Target : $0.0133
SL : $0.0162