如何对大小不断变化的列表的所有元素进行 Thread.join() ？

Question

假设我有大量工作线程都在积极处理，并且有一个主管线程等待它们全部完成。传统上我可以做这样的事情：

for(Worker w:staff){
    w.start();
}
for(Worker w:staff){
    w.join();
}

..一切都会好起来的。然而，在这种情况下，我的工作人员列表（ArrayList 工作人员）的大小是可变的，并且可能会在任意时间发生变化。我最好的知识告诉我这样的事情应该有效：

synchronized(this){
    for(Worker w:staff){
        w.start();
    }
}
while(true){ //this loop will keep the supervisor running until all workers have stopped
                  //interrupts will occur when changes to the size of staff list occur
    try{
        Iterator<Worker> it;
        synchronized(this){
            it = staff.iterator();
        }
        while(it.hasNext()){
            Worker w = it.next();
            w.join();
        }
        return;
    }catch(InterruptedException ie){continue;}
}

然而，这仍然会导致在线上出现 conncurrentModificationException

Worker w = it.next();

...这对我来说似乎很奇怪，因为我认为一旦您检索了迭代器，它就与列表本身分开了。我的下一个想法是克隆迭代器或人员列表，以便它与原始更改列表分开，但我想我应该先给你们专家一个机会。

Answer 1

如果对 Iterator 实例外部的底层集合进行任何更改，则 Iterator 实例将失效。

您为什么不考虑使用 ExecutorService 来代替？让 Worker 实现 Callable，然后使用该服务的其中一个 invokeAll() 方法。

CyclicBarrier 或 CountDownLatch 是较低级别的工具，可用于构建类似的功能。

Answer 2

当您尝试在迭代器部分完成的情况下修改列表时，您会收到 ConcurrentModificationException，但在您的代码示例中没有添加或删除列表的代码，因此问题出在代码的其他位置。

使用 Interator 时，基本上不要从列表中删除或添加项目，如果必须删除，可以使用 Iterator.remove() 而不是 List.remove() 来删除项目。