ExecutorService: FIFO Bestellung von Schlüsseln

Question

ich nach Möglichkeiten, bin auf der Suche eine ExecutorService machen FIFO durch einen Gegenstand (Schlüssel) bestellt werden, das heißt

1. für einen bestimmten Schlüssel, werden die Ereignisse in der sie verarbeitet werden, angekommen .
2. Für einen bestimmten Schlüssel wird jeweils nur ein Ereignis verarbeitet.

Netty 3 hat aber es ist zu Netty gebunden.

Guava hat EventBus, aber es ist unklar, ob es FIFO garantiert.

Ich könnte den Schlüssel mit etwas wie JKeyLockManager sperren, aber um FIFO zu garantieren, würde ich riskieren, Konflikte im Dispatcher-Thread.

Gibt es irgendwelche allgemeinen Lösungen für dieses Problem da draußen?

Answer 1

Wenn Sie Einfachheit wollen, würde ich eine Reihe von FIFO Testamentsvollstrecker wie diese

static final int executors = Runtime.getRuntime().availableProcessors() * 2; 
ExecutorService[] executors = new ExecutorService[executors]; 
// fill with single threaded executors. 

public Future submit(Object actorId, Runnable r) { 
    int h = (actorId.hashCode() & 0x7FFF_FFFF) % executors; 
    return executors[h].submit(r); 
} 

verwenden, wenn die Arbeitsbelastung sehr unausgewogen ist, wird diese damit beschäftigt alle CPUs halten, ohne die Notwendigkeit einer Verriegelung.