Недавно делал быстрый прототип асинхронного приложения в котором требовалось вызывать много синхронного кода. Да, я знаю, что это не лучший дизайн, но нужно было быстрое решение на один процесс и без очередей. Поэтому я выполнял код в потоках.
Выглядело это примерно так:
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
The Kingfisher $BTC GEX+ is showing some heat!
🟣🔴 Market makers are likely to amplify price swings in the near term.
Watch out for big moves around IV 55, where they're less exposed.
Current bracket [54k, 67k]
#BTC#Options#GEX#Volatility (Not financial advice, DYOR!)
Did you know that BIT exchange has launched the world’s first #TON#options? 👀
BIT’s hosting an #AMA to discuss “How & Why You Need to Trade #TONOptions”
📅Feb 8 2023
⏰19:00PM(SGT)
❓ RT with your UID & comment Qs
🎁 Selected Qs will be rewarded 10USDT each
📍Set your reminder 👉🏼http://bit.ly/3DGN3oz
We'll see you at this 🔥 AMA.
Nasdaq Proposes Huge Options Limit Increase
Nasdaq seeks to raise position and exercise limits for iShares Bitcoin Trust ETF (IBIT) options from 25,000 to 250,000 contracts. Awaiting SEC's approval or denial.
#Nasdaq#Bitcoin#ETF#IBIT#Options#SEC#Crypto#VC
🚀 Bitcoin and Ethereum Options Set to Expire Today
Bitcoin options valued at $1.9 billion are scheduled to expire today at 8:00 a.m. UTC. According to NS3.AI, Ethereum options worth $330 million will also reach expiration at the same time.
#Bitcoin#Ethereum#Options#Expiration#Cryptocurrency#Trading#BTC#ETH
TECHNICAL SUPPORT ON DAILY BASIS
WITH THE BEST TRUSTED AND TRIED TECHNICAL INDICATORS
FUNDAMENTAL ANALYSIS FOR LONG TERM STOCKS
COMMODITY PIONEER
EXCEPTIONAL IN INDEX OTIONS BASED ON OI ANALYSIS
#OPTIONS
#FUTURES
#EQUITYCASH
#MCX
FOR PREMIUM MEMBERSHIP
CALL /DM
https://wa.me/918618508145
TECHNICAL SUPPORT ON DAILY BASIS
WITH THE BEST TRUSTED AND TRIED TECHNICAL INDICATORS
FUNDAMENTAL ANALYSIS FOR LONG TERM STOCKS
COMMODITY PIONEER
EXCEPTIONAL IN INDEX OTIONS BASED ON OI ANALYSIS
#OPTIONS
#FUTURES
#EQUITYCASH
#MCX
FOR PREMIUM MEMBERSHIP
CALL /DM
https://wa.me/918618508145
TECHNICAL SUPPORT ON DAILY BASIS
WITH THE BEST TRUSTED AND TRIED TECHNICAL INDICATORS
FUNDAMENTAL ANALYSIS FOR LONG TERM STOCKS
COMMODITY PIONEER
EXCEPTIONAL IN INDEX OTIONS BASED ON OI ANALYSIS
#OPTIONS
#FUTURES
#EQUITYCASH
#MCX
FOR PREMIUM MEMBERSHIP
CALL /DM
https://wa.me/918618508145
TECHNICAL SUPPORT ON DAILY BASIS
WITH THE BEST TRUSTED AND TRIED TECHNICAL INDICATORS
FUNDAMENTAL ANALYSIS FOR LONG TERM STOCKS
COMMODITY PIONEER
EXCEPTIONAL IN INDEX OTIONS BASED ON OI ANALYSIS
#OPTIONS
#FUTURES
#EQUITYCASH
#MCX
FOR PREMIUM MEMBERSHIP
CALL /DM
https://wa.me/918618508145
TECHNICAL SUPPORT ON DAILY BASIS
WITH THE BEST TRUSTED AND TRIED TECHNICAL INDICATORS
FUNDAMENTAL ANALYSIS FOR LONG TERM STOCKS
COMMODITY PIONEER
EXCEPTIONAL IN INDEX OTIONS BASED ON OI ANALYSIS
#OPTIONS
#FUTURES
#EQUITYCASH
#MCX
FOR PREMIUM MEMBERSHIP
CALL /DM
https://wa.me/918618508145
TECHNICAL SUPPORT ON DAILY BASIS
WITH THE BEST TRUSTED AND TRIED TECHNICAL INDICATORS
FUNDAMENTAL ANALYSIS FOR LONG TERM STOCKS
COMMODITY PIONEER
EXCEPTIONAL IN INDEX OTIONS BASED ON OI ANALYSIS
#OPTIONS
#FUTURES
#EQUITYCASH
#MCX
FOR PREMIUM MEMBERSHIP
CALL /DM
https://wa.me/918618508145