java-这个用例的最佳集合是什么？

Question

我有一个密集更新的列表，所以我将它们分组在一起，并在单个线程中作为批处理作业执行它们。其他线程可以随时发送更新。

class ItemUpdateJob {
    int itemId;
    int number;
}

当调度要排队更新的作业时，我想要一个集合，如果作业已经存在，我可以在其中修改作业（假设itemId为键）。在这个例子中：

existingItemJobInQueue.number += requestedItemJob.number;

因此，队列不会开始为同一项提供数千个作业。当作业开始执行时，我需要以某种方式在队列中循环，但是在更新作业时，它不应该被更新（每个项目都应该有自己的锁吗？）。

for (ItemUpdateJob job : jobQueue) {
    updateItem(job);
}

更新作业后，应立即将其从队列中删除。最好的方法是什么？目前，我正在考虑使用一个HashMap，将项id作为键，然后每个项都有一个锁，可以防止在更新项时修改现有作业。不过，这将导致在等待更新完成时暂停（释放锁）。

Answer 1

在我看来，似乎你需要一个以上的集合组合。也许是这样的？

public class JobHandler {

  //jobs still in the queue, map for a quick lookup
  private final Map<Integer, ItemUpdateJob> waitingJobs;
  //jobs still waiting to be run
  private final Queue<ItemUpdateJob> jobQueue;

  public JobHandler(Collection<ItemUpdateJob> jobs) {
    this.waitingJobs = new HashMap<>();
    this.jobQueue = new LinkedList<>();
    this.init(jobs);
  }
  
  private void init(Collection<ItemUpdateJob> jobs) {
    for (ItemUpdateJob job : jobs) {
      this.waitingJobs.put(job.itemId, job);
      this.jobQueue.add(job);
    }
  }

  public ItemUpdateJob getNextJobToRun() {
    ItemUpdateJob nextJob = this.jobQueue.poll();
    if (nextJob != null) {
      this.waitingJobs.remove(nextJob.itemId);
    }
    return nextJob;
  }

  public void addJob(ItemUpdateJob job) {
    this.waitingJobs.put(job.itemId, job);
    this.jobQueue.add(job);
  }

  public boolean updateJob(ItemUpdateJob updateJob) {
    if (this.waitingJobs.containsKey(updateJob.itemId)) {
      //job is currently waiting for execution, so update it
      this.waitingJobs.get(updateJob.itemId).number += updateJob.number;
      return true;
    } else {
      //job is currently being run, or no such job at all
      //so adding it at the end of the queue to wait for it's turn
      this.addJob(updateJob);
      return false;
    }
  }
}

java.util.队列看起来像是一个很好的匹配-FIFO执行顺序的作业和一个Map在更新当前等待的作业时快速查找。请记住，某些Queue实现有容量限制，显然这需要同步。