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

Question

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

Class Employee{
   int EmployeeId;
}

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

如何确保数据以递增序列的方式根据员工ID的序列插入数据库。例如：

如果数组中的对象具有员工ID 6、8和4，那么这些对象应该按照员工ID 4、6和8在数据库中的顺序插入数据库。如何为此编写多线程代码？

更新：请忽略数据库部分，如果它令人困惑，我的主要意图是并行处理但按顺序处理。

Answer 1

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

首先，您需要在实现可运行的类中按顺序组织这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写一个简单的建议：

/*
 * 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对象。但是，线程任务为每个员工对象按顺序执行任务列表。

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

希望这有帮助

Answer 2

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

你可以很容易地做到这一点与一个线程。你可以走这条安全的路。线程不保证任何关于优化和排序的事情。如果预处理成本高昂，请以线程方式进行，然后确保所有线程都以倒计时锁存完成，然后插入到数据库中。

穿线可能导致死亡、窒息、发冷、发烧、溺水、感染、恶心以及无法控制重型机械。