Bulkhead

// ERRADO: um pool para tudo. A dependencia lenta consome as 100 vagas
// e derruba ate as rotas que nunca falam com ela.
const pool = criarPool({ max: 100 });

// CERTO: comparticoes. Cada dependencia tem um teto proprio,
// e o pior caso de uma nao alcanca as outras.
class Comparticao {
  private emUso = 0;

  constructor(private readonly limite: number) {}

  async executar<T>(fn: () => Promise<T>): Promise<T> {
    if (this.emUso >= this.limite) {
      // Rejeitar rapido e melhor que enfileirar sem limite:
      // fila infinita so adia a falha e piora a latencia de todos.
      throw new Error("comparticao cheia");
    }
    this.emUso++;
    try {
      return await fn();
    } finally {
      this.emUso--;
    }
  }
}

const recomendacao = new Comparticao(10);  // pode afogar sozinha
const pagamento    = new Comparticao(40);  // critico, tem folga
const catalogo     = new Comparticao(50);

import asyncio

class Comparticao:
    """Teto de concorrencia por dependencia, com rejeicao rapida."""

    def __init__(self, limite: int):
        self._sem = asyncio.Semaphore(limite)

    async def executar(self, coro):
        # locked() antes de acquire(): queremos REJEITAR, nao enfileirar.
        if self._sem.locked():
            raise RuntimeError("comparticao cheia")
        async with self._sem:
            return await coro

# Cada dependencia com seu teto. A soma pode passar do pool total —
# o objetivo nao e reservar capacidade, e impedir que UMA tome tudo.
recomendacao = Comparticao(10)
pagamento = Comparticao(40)