Недавно делал быстрый прототип асинхронного приложения в котором требовалось вызывать много синхронного кода. Да, я знаю, что это не лучший дизайн, но нужно было быстрое решение на один процесс и без очередей. Поэтому я выполнял код в потоках.
Выглядело это примерно так:
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
An OTC whale “0xd45” deposited 670 $cbBTC worth $50.19M into #Coinbase.
The whale still holds 138,203 $ETH worth $329.33M and 3,000 $cbBTC worth $226.66M.
https://intel.arkm.com/explorer/address/0xd4584bf988c9e8994688b56484e2f74ceaeefb20
https://x.com/OnchainLens/status/2044057234699891113
Follow @onchainlens for more onchain updates
BlackRock deposited 1,249.68 $BTC ($131.55M) into #Coinbase. In total, they deposited 5362.37 $BTC ($560.94M), in the past 2 days.
They also withdrew 27,241.4 $ETH, worth $69.25M from #Coinbase.
https://intel.arkm.com/explorer/entity/blackrock
Blackrock withdrew 2,607 $BTC ($177.56M) and 28,391 $ETH ($59M) from #Coinbase.
https://intel.arkm.com/explorer/entity/blackrock
https://x.com/OnchainLens/status/2041673016653050293
Follow @onchainlens for more onchain updates
Over the past 2 hours, thomasg.eth (@thomasg_eth) has sold 4,700 $ETH for $9.67M $USDC and deposited 6,345 $ETH ($13.03M) into #Coinbase, losing ~$1.4M.
He also sold 13,150 $AAVE for 364 $ETH ($750K) and $459,618 $USDC, and deposited it into #Coinbase.
https://intel.arkm.com/explorer/entity/thomasg
https://x.com/OnchainLens/status/2040952872805032291
Follow @onchainlens for more onchain updates
BlackRock deposited 1,360 $BTC ($90.28M) 15,103 and $ETH ($30.82M) into #Coinbase.
https://intel.arkm.com/explorer/entity/blackrock
https://x.com/OnchainLens/status/2039654986439926157
Follow @onchainlens for more onchain updates
BlackRock deposited 68,568 $ETH ($139.87M) and 612 $BTC ($41.4M) into #Coinbase
https://intel.arkm.com/explorer/entity/blackrock
https://x.com/OnchainLens/status/2037474772364443808
Follow @onchainlens for more onchain updates
Blackrock deposited 1,133.65 $BTC worth $78.83M and 15,405 $ETH ($32.02M) into #Coinbase and likely to deposit more.
https://intel.arkm.com/explorer/entity/blackrock
https://x.com/OnchainLens/status/2037128859217522960
Follow @onchainlens for more onchain updates
After a month of dormancy, a whale withdrew 11,999 $ETH (worth $26M) from #Coinbase and sent it for staking.
Currently, the whale holds 22,618 $ETH ($49M), making a profit of $1.2M.
Address: 0xd5549b9e07c1ff372b1a3912e184213bfe37bf25
https://x.com/OnchainLens/status/2036965329080062253
Follow @onchainlens for more onchain updates
13 hours ago, Clifton Collins, an Irish drug dealer, deposited 500 $BTC ($35.44M) into #Coinbase after nearly 10 years of being presumed lost.
Collins bought 6,000 $BTC in 2011–2012 from the proceeds of growing and dealing weed, and split it across multiple wallets.
After his 2017 arrest, the house was cleared out, and his belongings were sent to a landfill.
https://intel.arkm.com/explorer/entity/clifton-collins
https://x.com/OnchainLens/status/2036618949052571744
Follow @onchainlens for more onchain updates
BlackRock withdrew 2,267 $BTC worth $157.77M from #Coinbase in the past 10 hours.
https://intel.arkm.com/explorer/entity/blackrock
https://x.com/OnchainLens/status/2036608043862126958
Follow @onchainlens for more onchain updates