Devo scrivere la mia versione personale di una coda limitata. Deve essere thread sicuro. Il consumo di questa coda si basa su un sistema prioritario, in cui un consumatore effettua una richiesta per un oggetto in coda.
La coda può avere molti produttori e molti consumatori. I consumatori arrivano e registrano le loro richieste in base a determinati criteri intorno all'oggetto. Quando un oggetto viene messo in coda, i consumatori che registrano prima la richiesta dovrebbero ricevere priorità per ricevere l'oggetto. Se un thread consumatore tenta di ottenere un oggetto che ha registrato un interesse ma quell'oggetto non è lì, il consumatore blocca fino a quando il produttore inserisce l'oggetto e avvisa il consumatore.
Ho fatto il mio tentativo qui sotto, ma la mia implementazione finora è solo un'implementazione ArrayBlockingQueue. non copre la registrazione di tipi di oggetti.
Ho bisogno di una sorta di modello di osservatore?