ExecutorServiceの：キー

Question

私はExecutorServiceのを作る方法を探しています

により、FIFOの順序はFIFO指定されたキーのすなわち

1. 、オブジェクト（キー）で注文することが、イベントは、彼らが到着した順に処理されます。
2. 特定のキーでは、一度に1つのイベントしか処理されません。

Netty 3はですが、Nettyに関連付けられています。

グアバはEventBusですが、FIFOを保証するかどうかは不明です。

JKeyLockManagerのようなものを使用してキーをロックすることができますが、FIFOを保証するために、ディスパッチャスレッドで競合する危険性があります。

この問題の一般的な解決方法はありますか？

Answer 1

あなたはシンプルにしたい場合は、ワークロードが、これはロックを必要とせずに、忙しいすべてのCPUを維持する非常にアンバランスである場合を除き、私はこの

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); 
} 

のようなFIFOエグゼキュータの数を使用します。