Java:并发更新状态

Question

• 我有很多任务，它们都有状态。状态被持久化到数据库。目前，我将所有状态保存在一个线程中： executor = Executors.newSingleThreadExecutor()；Executor.submit( UpdateStatusTask(taskId，status))； 这是安全的，但会杀死并发性。
• 另一方面，如果我添加更多的线程，它可能会导致数据损坏--以后的任务状态可能会被更好的线程覆盖。
• 我看到并行执行状态更新的解决方案，但以这种方式，一个任务的状态更新总是在单个线程上执行。如果将runnables放入队列中，它将确保一致性(在早期状态更新之后执行后续状态更新)。

有任何standart/Apache/Guava等实用工具类来执行这样的任务吗？

Answer 1

您应该用同一个线程更新同一任务的状态。

public class TaskStatusUpdater {

    private final int threadCount;
    private final ExecutorService[] executors;

    public TaskStatusUpdater(int threadCount) {
         this.threadCount = threadCount;
         executors = new ExecutorService[threadCount];
         for (int i = 0; i < threadCount; i++) {
             executors[0] = Executors.newSingleThreadExecutor();
         }
    }

    public void submitTask(int taskId, Runnable task) {
         int index = Integer.hashCode(taskId) % threadCount;
         executors[index].submit(task);
     }
 }