Como os fluxos entre si percebiam que era necessário enviar uma solicitação ou não (contador comum Circuit Breaker em um ambiente multithread)?

В многопоточной среде общий счётчик Circuit Breaker обычно реализуется с использованием атомарных операций и синхронизации, чтобы потоки могли корректно видеть и изменять состояние счётчика.

Основные подходы:

• Атомарные переменные (например, AtomicInteger в Java) позволяют безопасно увеличивать или уменьшать счётчик без блокировок.
• Волатильные переменные гарантируют видимость изменений между потоками.
• Блокировки или синхронизированные методы обеспечивают эксклюзивный доступ при обновлении счётчика.

Таким образом, каждый поток перед отправкой запроса проверяет состояние Circuit Breaker, читая атомарный счётчик. Если счётчик превышает порог ошибок, запросы блокируются. При успешных ответах счётчик сбрасывается или уменьшается.

Пример на Java с использованием AtomicInteger:

AtomicInteger failureCount = new AtomicInteger(0);
int failureThreshold = 5;

public boolean canSendRequest() {
    return failureCount.get() < failureThreshold;
}

public void onFailure() {
    failureCount.incrementAndGet();
}

public void onSuccess() {
    failureCount.set(0);
}

Так потоки синхронизируют доступ к счётчику без явных блокировок, обеспечивая корректное поведение Circuit Breaker.