Недавно делал быстрый прототип асинхронного приложения в котором требовалось вызывать много синхронного кода. Да, я знаю, что это не лучший дизайн, но нужно было быстрое решение на один процесс и без очередей. Поэтому я выполнял код в потоках.
Выглядело это примерно так:
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
#IDEX/USDT analysis :
#IDEX is currently in a downtrend and trading below the 200 exponential moving average (EMA). The price is encountering resistance from the 200 EMA and the resistance zone. It is anticipated to decline from there and test a lower low.
TF : 2h
Entry : $0.02875
Target : $0.02650
SL : $0.03024
#IDEX/USDT analysis :
#IDEX has recently broken out above the resistance zone and the 200 EMA. The price is likely to continue its bullish momentum and test higher levels.
TF : 15min
Entry : $0.03760
Target : $0.03894
SL : $0.03672
📊#IDEX pumped with a good volume from the horizontal support. Currently, it is facing the descending trendline, MA 100 and the Ichimoku cloud resistance. We've to keep an eye on a solid breakout of the Ichimoku cloud, which would confirm the upward direction.👀
❄️@signals_bitcoin_crypto❄️
❄️@Shadow_support0o❄️
📊#IDEX is forming a descending triangle and price is heading toward a decision area. The support is $0.0469-$0.0485 area and a break below this support area will bring a heavy sell-off. The resistance is $0.052-$0.0522 area and we will only open a long position after a break above the resistance area.🚀
❄️@signals_bitcoin_crypto❄️
❄️@Shadow_support0o❄️
Эксклюзивно про Т-90МС: с выставочного подиума – в бой
Новейший Т-90МС, который в феврале этого года был звездой международной выставки#IDEX в Абу-Даби, уже выполняет боевые задачи в составе российских танковых подразделений.
Машина, которую мы впервые показали за рубежом, была доработана с учётом богатейшего опыта СВО. И в наши войска была отправлена практически в той же комплектации, что и демонстрировалась на выставке в ОАЭ. Изменение коснулось цвета: с «выставочного» песочного камуфляжа танк перекрасили в стандартный армейский зеленый.
Ко Дню танкиста публикуем эксклюзивное видео всего этого пути!
В этом ролике – вся история: от транспортировки танка на выставку, его работы на стенде Рособоронэкспорта и до возвращения домой, перекраски и отправки героям-танкистам.
#КонцернУВЗ#Т90