Недавно делал быстрый прототип асинхронного приложения в котором требовалось вызывать много синхронного кода. Да, я знаю, что это не лучший дизайн, но нужно было быстрое решение на один процесс и без очередей. Поэтому я выполнял код в потоках.
Выглядело это примерно так:
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
⨳ 27.04.26 / 28.04.26 ⨳ Обновление тикток ENJIN (@/official_enjin):
«#/DDD с Эймей из cosmosy ♪
Спасибо за сотрудничество ✨»¹ (видео 1)
«#/DDD с Диханой из PRODUCE 101 ♪
Спасибо за сотрудничество ✨»¹ (видео 2)
«#/OSOL вместе с cosmosy 🤍
Спасибо за сотрудничество ✨»¹ (видео 3)
¹ Участницы cosmosy приняли участие в челленджах на песни «Day by day by day» и «One Snow One Love» вместе с участниками ENJIN
#othersns@cosmosy#cosmosy
⨳ 16.04.26 ⨳ Обновление твиттера MUPLY (@/MUPLY_PLAYLIST):
«Химеша исполняет рэп-сегмент песни „Paradise ~ I need you ~“» (видео 1)
«Это мой рай» (видео 2)
#othersns@cosmosy#cosmosy
⨳ 12.04.26 ⨳ Обновление твиттера MUPLY (@/MUPLY_PLAYLIST):
«Враньё!! Это не ёкай, а фея!!!!! Вперёд смотреть на подготовку к шоу талантов cosmosy✨»
Новый эпизод „The Silence of IDOL“ с cosmosy на платформе MUPLY: https://youtu.be/9rQAPjWpv1Q
#othersns@cosmosy#cosmosy
⨳ 09.04.26 ⨳ Обновление твиттера MUPLY (@/MUPLY_PLAYLIST):
«pov: 4 обязательных навыка для тренировочного лагеря
Начиная с сегодняшнего дня, я буду практиковать только их и обязательно займу место в первом ряду шоу талантов cosmosy
Смотрите на платформе MUPLY в эту субботу, 11 апреля, новый эпизод „The Silence of IDOL“ с участием cosmosy ✨»
#othersns@cosmosy#cosmosy
⨳ 08.04.26 ⨳ Обновление твиттера MUPLY (@/MUPLY_PLAYLIST):
«На меня напали девочки-ёкаи...
„Моё сердце было атаковано, потому что они были милыми“
Смотрите на платформе MUPLY в эту субботу, 11 апреля, новый эпизод „The Silence of IDOL“ с участием cosmosy ✨»
#othersns@cosmosy#cosmosy
⨳ 07.04.26 ⨳ Обновление твиттера NPOP (@/NPOP_OFFICIAL):
«𝗡𝗣𝗢𝗣 𝗟𝗜𝗠𝗜𝗧𝗘𝗗 𝗘𝗗𝗜𝗧𝗜𝗢𝗡 - 𝗦𝗜𝗗𝗘 𝗔
В этом дерзком треке⸝⸝⸝⋆
Falling for you was my big mistake
За обликом чудовищ скрывается история девушек, сокрывших любовь ﾟ･｡♥️｡･ﾟ
Performance Video с участием cosmosy появится на YouTube-канале «NPOP» завтра, 8 апреля, в 14:00 по МСК»
#othersns@cosmosy#cosmosy