Недавно делал быстрый прототип асинхронного приложения в котором требовалось вызывать много синхронного кода. Да, я знаю, что это не лучший дизайн, но нужно было быстрое решение на один процесс и без очередей. Поэтому я выполнял код в потоках.
Выглядело это примерно так:
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
📩#BNBUSDT 30m | Mid-Term
📉Long Entry Zone: 560.11-543.61
🎯 - Strategy Accuracy: 89%
⏳ - Signal details:
Target 1: 564.04
Target 2: 567.41
Target 3: 570.77
Target 4: 580.86
_
🧲Trend-Line: 543.61
❌Stop-Loss: 540.34
💡After reaching the first target you can put the rest of the position to breakeven
📩#BNBUSDT 30m | Mid-Term
📉Long Entry Zone: 566.42-543.30
🎯 - Strategy Accuracy: 89.78%
Last 5 signals: 100.0%
Last 10 signals: 100.0%
Last 20 signals: 100.0%
⏳ - Signal details:
Target 1: 569.14
Target 2: 571.86
Target 3: 574.58
Target 4: 582.73
_
🧲Trend-Line: 543.30
❌Stop-Loss: 540.70
💡After reaching the first target you can put the rest of the position to breakeven
After falling from the support level of $500.0, #BinanceCoin reached the support level of $400.0 and recovered and is now trading above both levels.
As you can see in the chart, a dynamic resistance still prevents #BNBUSDT growth, so in the first step, crossing and breaking this resistance can be a sign of the continuation of the upward trend in the daily time frame.
So far, BNBUSDT has hit the dynamic resistance 2 times and failed to break it, these collisions may reach up to 5 times and then the price will start to grow. The current price movement scenario is between the $400.0 support and the dynamic resistance.
📩#BNBUSDT 30m | Mid-Term
📉Short Entry Zone: 619.76-636.57
🎯 - Strategy Accuracy: 93.69%
Last 5 signals: 100.0%
Last 10 signals: 95.0%
Last 20 signals: 96.77%
⏳ - Signal details:
Target 1: 616.04
Target 2: 612.32
Target 3: 608.60
Target 4: 597.45
_____
🧲Trend-Line: 636.57
❌Stop-Loss: 640.39
💡After reaching the first target you can put the rest of the position to breakeven
#ID20000037367