java - 具有主键保留序列更新的数据库多线程

Question

有大量数据需要处理，我试图使它们并行。

class Item{
    Integer id;
    String data;
}


ExecutorService executor = Executors.newFixedThreadPool(10);

for (Item item : items) {
            executor.execute(() -> putItemToDB(item));
        }

但出现的问题是，在测试用例中，我对同一个主键有前 6 个任务。具有相同主键(id)的任务顺序很重要，不得更改。目前，我对此无法保证。

示例:

items = [{id: 1, data: "a"}, {id: 1, data: "b"}, {id: 2, data: "g"}]

我必须知道a在b之前，并且在线程池中运行所有任务并不能保证这一点。 a 有可能覆盖 b。

有什么好的设计模式可以解决这个问题吗？

Answer 1

此用例的良好设计模式是为每个 id 使用单独的 Actor 实例。项目被发送到相应的参与者并按顺序保存在输入队列中。 Actor 从队列中取出下一个项目并将其保存在数据库中。要查找键的参与者，可以使用 HashMap。

如果有太多不同的 id 和太多的 actor，actor 可以检查其输入队列是否为空一段时间，然后从 HashMap 中注销自己。

还可以优化这样的参与者，以便可以使用单个项目的变量来代替输入队列。如果在前一个项目尚未写入数据库时​​另一个项目到达，新项目只会重写前一个项目 - 无论如何，写入旧项目没有任何意义，它将在数据库中被覆盖。

可以在https://github.com/akaigoro/CodeSamples/blob/master/src/main/java/actor/simpleactor/SimpleActor.java找到一个简单的 Actor 开始