Недавно делал быстрый прототип асинхронного приложения в котором требовалось вызывать много синхронного кода. Да, я знаю, что это не лучший дизайн, но нужно было быстрое решение на один процесс и без очередей. Поэтому я выполнял код в потоках.
Выглядело это примерно так:
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
#BSW/USDT analysis :
#BSW is currently in a downtrend and is trading below its 200-day exponential moving average. It has broken down below its support level and is retracing. It is expected to test the support zone before declining further. The swing low level will be tested.
TF : 2h
Entry : $0.0417
Target : $0.0319
SL : $0.0487
#BSW/USDT analysis :
#BSW is currently in an uptrend and is undergoing a correction phase. It is expected that the price will retrace to the support zone for a retest before continuing its bullish momentum. It is recommended to wait for this retest of the support zone before considering any long entry positions.
TF : 2H
Entry : $0.0900
Target : $0.1070
SL : $0.0820
#BSW/USDT analysis :
#BSW is in a downtrend, making lower lows (LLs) and lower highs (LHs), and is trading below the 200 EMA. The price has broken and retested the previous support zone, which is now acting as resistance. The price is likely to continue its bearish momentum and test new lows. Wait for a pullback for short entry.
TF : 15min
Entry : $0.0571
Target : $0.0550
SL : $0.0583
#BSW/USDT analysis :
#BSW has recently tested the resistance zone in a correction phase. It is expected that the price will face rejection at this level and continue its downward movement. It is recommended to wait for the price to break below the $0.0469 level before considering an entry point.
TF : 2H
Entry : $0.0469
Target : $0.0410
SL : $0.0504
Mamma mia!
Dolphin called this morning’s crash for some coins at 6am GMT+3 with high probability short signals!
While traders banked +15% 🤑🤑 gains on #BSW#LEVER dips, others grabbed nearly +5%.
Our users enjoy effortless profits thanks to advanced AI. Stop losing - level up your trading game and start winning today with our tools designed for traders!
www.coinlegs.com
#Germania#Bundestag
Il gruppo parlamentare della #Linke|LEFT ha deciso di sciogliere il gruppo dopo aver perso la quota minima di 37 deputati.
Ora si prevede la nascita di due nuovi "Gruppe": da un lato i restanti 28 deputati della Linke e dall'altro i 10 deputati di #BSW|Sinistra populista euroscettica. Rispetto ai gruppi parlamentari, un gruppe ha leggermente meno diritti parlamentari e riceve anche meno sostegno finanziario da parte del tesoro statale. Per approvare un gruppe e determinarne i suoi diritti è necessaria una delibera del Bundestag.
@OsservatorioEsteri