Недавно делал быстрый прототип асинхронного приложения в котором требовалось вызывать много синхронного кода. Да, я знаю, что это не лучший дизайн, но нужно было быстрое решение на один процесс и без очередей. Поэтому я выполнял код в потоках.
Выглядело это примерно так:
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
#IOTA/USDT analysis :
#IOTA bounced off the tested support zone with strong volume. A breakout above the trendline is expected, resuming its uptrend. Watch for a break above the $0.4870 level to consider going long. The outlook remains bullish.
TF : 1H
Entry : $0.4870
Target : $0.6000
SL : $0.4212
#IOTA/USDT analysis :
#IOTA is currently consolidating sideways within the support and resistance zones. The price has recently bounced back from the support zone and is expected to continue its momentum to test the resistance zone.
TF : 1D
Entry : $0.1250
Target : $0.1443
SL : $0.1127
#IOTA/USDT analysis -
#IOTA is in a downtrend on the lower time frame, trading below the 200 EMA. Following a corrective pullback, the price is currently holding the support level. A breakdown of this support has triggered an entry in the price, leading to a continuation of the bearish trend. The previous low will be the target level.
TF : 1h
Entry : $0.1670
Target : $0.1493
SL : $0.1797
🔎#IOTA - Новый цикл ?
В 18 декабря представил глобальный расклад по монете IOTA
Спустя 2 месяца монета пришла в зону покупки и сейчас показывает себя отлично чтобы продолжить свой рост
В ближайшие 3 месяца жду рост до уровня 0.45
💻https://ru.tradingview.com/chart/IOTAUSDT/K4o0pgo9-iota-novyj-tsikl/
Как вам эта инвест идея ? пишите в комментарии
Торгуйте с умом
@ProfessorKlinkov