Supponiamo di avere un'applicazione che accetta un flusso arbitrario di oggetti. Alcuni di questi oggetti appaiono più volte in questo stream. Il compito della mia applicazione è quello di filtrare quegli oggetti duplicati dallo stream e passare una versione duplicata del flusso alla prossima applicazione. Questo di solito è banale, ma per motivi di ridondanza voglio creare più istanze di questo duplicato-correttore su più macchine in modo che possa continuare a funzionare quando una macchina muore per qualsiasi motivo. Come faccio a fare un tale controllo duplicato se viene eseguito in parallelo? Come puoi sincronizzare questo senza bloccare costantemente tutte le istanze tranne una? È persino possibile?
Nota: non sto cercando una particolare implementazione o una soluzione in qualche lingua, questa è più una domanda concettuale.