Для синхронизации воркеров через счётчики в Redis можно использовать атомарные операции инкрементации и блокировки.

Пример подхода:

Каждый воркер при старте увеличивает общий счётчик с помощью INCR.
Когда нужно дождаться, пока все воркеры достигнут определённой точки, можно проверять значение счётчика.
Для ожидания можно использовать блокирующие операции или циклы с паузами.
После завершения работы воркер уменьшает счётчик с помощью DECR.

Пример на Go с использованием клиента go-redis:

import (
    "context"
    "github.com/go-redis/redis/v8"
    "time"
)

var ctx = context.Background()

func worker(redisClient *redis.Client, key string, totalWorkers int) {
    // Увеличиваем счётчик
    redisClient.Incr(ctx, key)

    // Ждём, пока все воркеры увеличат счётчик
    for {
        val, _ := redisClient.Get(ctx, key).Int()
        if val >= totalWorkers {
            break
        }
        time.Sleep(100 * time.Millisecond)
    }

    // Выполняем работу

    // По окончании уменьшаем счётчик
    redisClient.Decr(ctx, key)
}

Такой подход позволяет синхронизировать старт или этапы работы между воркерами через Redis счётчик.

Как реализовать синхронизацию воркеров через счётчики в Redis?