Как потоки между собой понимали, что нужно отправлять запрос или нет (общий счётчик Circuit Breaker в многопоточной среде)?

В многопоточной среде общий счётчик 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.