Java，通过多线程环境中的哈希将传入的工作均匀地划分

Java，通过多线程环境中的哈希将传入的工作均匀地划分

听起来您需要按每个调度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();  }}