听起来您需要按每个调度ID进行FIFO排序，所以理想的方法是将调度队列作为抽象。这可以解释您对散列不提供统一分发的担忧，因为某些调度队列可能比其他调度队列更活跃，并且在工作人员之间不公平地平衡。通过将队列与工作程序分开，您可以保留FIFO语义并均匀地分散工作。
提供这种抽象的非活动库是HawtDispatch。它与Java
6兼容。
一个非常简单的Java
8方法是使用CompletableFuture作为排队机制，使用ConcurrentHashMap进行注册，并使用执行程序（例如ForkJoinPool）进行计算。有关此想法的实现，请参阅EventDispatcher，其中注册是显式的。如果您的调度员更具动态性，那么您可能需要定期修剪地图。基本思想如下。
ConcurrentMap<String, CompletableFuture<Void>> dispatchQueues = ...public CompletableFuture<Void> dispatch(String queueName, Runnable task) { return dispatchQueues.compute(queueName, (k, queue) -> { return (queue == null) ? CompletableFuture.runAsync(task) : queue.thenRunAsync(task); });}更新（JDK7）
上述想法的后盾将通过番石榴翻译成类似以下内容：
ListeningExecutorService executor = ...Striped<Lock> locks = Striped.lock(256);ConcurrentMap<String, ListenableFuture<?>> dispatchQueues = ...public ListenableFuture<?> dispatch(String queueName, final Runnable task) { Lock lock = locks.get(queueName); lock.lock(); try { ListenableFuture<?> future = dispatchQueues.get(queueName); if (future == null) { future = executor.submit(task); } else { final SettableFuture<Void> next = SettableFuture.create(); future.addListener(new Runnable() { try { task.run(); } finally { next.set(null); } }, executor); future = next; } dispatchQueues.put(queueName, future); } finally { lock.unlock(); }}
