Недавно делал быстрый прототип асинхронного приложения в котором требовалось вызывать много синхронного кода. Да, я знаю, что это не лучший дизайн, но нужно было быстрое решение на один процесс и без очередей. Поэтому я выполнял код в потоках.
Выглядело это примерно так:
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
Доброго дня, братва ! По итогам матча молодёжки на прошлой неделе скажу от себя пару слов: это была одна из самых качественных поддержек команды за последнее время! Ни дождь, ни будний день не помешали отлично пошизить!
Разнообразный список песен и зарядов, в числе которых «Идёт фанат по городу», с лихвой подхватывали как молодые парни с горящими глазами, так и куча братвы, с которой прошли ни один десяток выездных и домашних матчей, члены ультрас-коллективов, и не только.
У игроков сверкали глаза, чему свидетельствует как ответная реакция после матча, так и статистика встречи.
Мы и дальше будем анонсировать такого рода походы на спортивные мероприятия, в скором времени которых будет ещё больше! Присоединяйтесь к нам и не забывайте, что Fan ID — убийца футбола!
#U_Brigade#Moscow#Spartak
В эту пятницу нас ждет принципиальный матч, хоть это и молодежное первенство по футболу — игра с «гудками» будет такой же ожесточенной по борьбе и накалу страстей как на поле, так и на трибунах!
Когда вы окажетесь на секторе активной поддержки, забудьте о своих телефонах, о срочных публикациях в соц.сети и о прочих делах на полтора часа игрового времени. От первой и до последней минуты матча важен твой голос! Видишь, что кто-то не шизит — сделай замечание и пой вместе с товарищем еще громче!
Этот матч для нас возможность показать отличие игр с настоящими фанатами от тех, куда приходят сторонники геноцида живого футбола!
Пятница. 19:00. «Сапсан Арена». Только красный верх, спартаковский шарф, бешеный настрой на шизу! Слушай команды заходящих и будь на одной волне с торсидой!
До встречи на стадионе!
#U_Brigade#Moscow#Spartak
Приветствуем всех!
Завтра нас ждёт долгожданный день — день, когда на первый за полтора года матч основы мы вернемся на нашу родную трибуну «В»! Никакие шаги на пути к смягчению бойкота наш движ не приемлет, поэтому завтра каждый обязан отдать поддержке всего себя, получить максимум эмоций и зарядить команду перед стартом сезона!
Ждем всех неравнодушных, кто разделяет нашу позицию по Fan ID, на стадионе «Спартак» во вторник! Если нижний ярус раскуплен полностью, то на верхний остаётся много свободных билетов.
Бери с собой шарф и красную футболку! Используйте подготовленный для праздника футбола стафф, слушайте команды заводящих и отложите мобильные устройства до финального свистка!
СНОВА ВСЕ НА СТАДИОН!
#U_Brigade#Moscow#Spartak
#Fratria#Ультра
🇷🇺 ONORE ai CADUTI
Donetsk
Repubblica Popolare di Donetsk
Federazione Russia
5/8/2025
( ⚔️ Qui giace, tra gli altri, Motorola, il mitico comandante del battaglione Sparta ).
#donetsk#Donbass#motorola#russia#europa#Defender#italia#spartan#Spartak
https://t.me/gianlucaprocaccinireport