Недавно делал быстрый прототип асинхронного приложения в котором требовалось вызывать много синхронного кода. Да, я знаю, что это не лучший дизайн, но нужно было быстрое решение на один процесс и без очередей. Поэтому я выполнял код в потоках.
Выглядело это примерно так:
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
🚢Более 1100 судов столкнулись с навигационными сбоями в Персидском заливе.
По данным аналитической компании Windward, за последние 24 часа свыше 1100 судов в Персидском заливе подверглись помехам GPS и AIS.
Зафиксированы масштабные и прерывистые сбои GNSS, влияющие на системы позиционирования, навигации и связи (включая AIS и VHF).
Операторам рекомендовано избегать района Персидского и Оманского заливов, северной части Аравийского моря и Ормузского пролива.
Суда под флагом США или с американскими экипажами обязаны держаться на расстоянии 30 морских миль от военных кораблей США и поддерживать постоянную связь с военно-морскими каналами.
Экипажам предписано дублировать GPS-позиционирование радиолокацией, визуальными пеленгами и иными методами.
По оценке Windward, отметки судов ошибочно «перемещались» в аэропорты, на АЭС и на сушу в Иране, Омане и ОАЭ. Выявлен минимум 21 новый кластер AIS-помех в водах у ОАЭ, Катара, Омана и Ирана.
Инциденты усиливают навигационные, регуляторные и операционные риски в одном из ключевых коридоров мировой энергетической торговли.
На фоне геополитической эскалации электронные помехи становятся самостоятельным фактором риска для судоходства, влияя на страхование, маршрутизацию и безопасность экипажей.
📌Windward Ltd. — международная компания в сфере морской аналитики и разведки, основанная в 2010 году, специализируется на анализе AIS-данных и оценке морских рисков. Акции обращаются на Лондонской фондовой бирже (AIM); компания является публичной и принадлежит институциональным и частным инвесторам.
#GNSS#AIS#Hormuz#MaritimeSecurity#ShippingRisk