如何按顺序进行多线程处理？

Question

这是我要解决的问题，但不确定如何解决：我有一个对象数组（例如大小为 100），每个对象都有一些 id。

Class Employee{
   int EmployeeId;
}

有 10 个线程将从这个数组中读取数据并插入 进入数据库。

如何确保数据按照EmployeeId的递增顺序插入到DB中。 例如：

如果数组中有 EmployeeID 为 6、8 和 4 的对象，则这些对象 应按 EmployeeID 4、6 和 8 在 DB 中的顺序插入 DB。 如何为此编写多线程代码？

更新：请忽略 DB 部分，如果它令人困惑，我的主要意图是同时处理但顺序。

Answer 1

我认为您不了解这里使用线程。 Threading¹ 适用于并行任务，其中（可能除了一些障碍）排序无关紧要，您的线程并行运行。你想要一个简单的循环或其他类型的串行行为。

你可以用一个线程轻松地做到这一点。你可以在这里走安全的道路。线程不保证任何关于优化和排序的事情。如果预处理很昂贵，请以线程方式进行，然后确保线程全部以CountdownLatch 结束，然后插入数据库。

¹穿线​​可导致死亡、窒息、寒战、发烧、溺水、感染、恶心和the inability to control heavy machinery。

Answer 2

如果我理解正确，对于数组的每个条目，您有一些任务必须按顺序执行（我假设是 10 个）。

首先，你需要在一个实现Runnable的类中按顺序组织这10个任务：

public class ThreadedTask implements Runnable {
    private Employee employee;
    public ThreadedWork(Employee employee) {
        this.employee = employee;
    }
    public void executeTaskList(Employee employee) {
        task1(employee);
        task2(employee);
        // ...
        task10(employee);
    }
    public void run() {
        executeTaskList();
        notify();
    }
}

然后，您可以实施以下解决方案之一：

1. 在数组中插入Employee对象，创建ThreadedTask对象并在线程上调用它的执行。
2. 在数组中插入所有Employee对象，然后使用for循环创建ThreadedTask对象并在线程上调用它的执行。

我将在这里为选项 2 写一个简单的建议：

/*
 * I am assuming that there`s an array called empArray, which holds 100 employees.
 * It's up to you to decide how it is populated.
 */
public void processEmployees() {
    // ...
    for(Employee e : empArray) {
        (new Thread(new ThreadedTask(e))).start()
    }
    // ...
}

如您所见，逻辑分为两部分：由您定义填充empArray 的方式，以及如何创建和执行ThreadedTask 对象。但是ThreadedTask 为每个Employee 对象按顺序 执行任务列表。

请注意，无法判断在任何给定时刻处理了哪个Employee 对象。所有员工都是并发处理的，但每个员工的任务是按顺序执行的。

希望对你有帮助