这里有一个循环,用于从 A GenericObjectPool 借用对象并在每个循环中提交给 Executor。然后,调用者必须等待所有 Exectuor 完成。
这是目前的代码 -
private ImplClass implObject;
private Future future;
for (Iterator iter = anArrayList.iterator(); iter.hasNext();) {
//Gets a GenericObjectPool Object
implObject = (ImplClass) this.getImplPool().borrowObject();
future = getExecutorServices().submit(implObject);
}
// Wait for Exectuor to complete
while (!future.isDone()) {
try {
Thread.sleep(Global.WaitTime());
} catch (InterruptedException iex) {
}
}
但这是错误的,因为未来只等待最后一个线程。我应该创建一个期货数组来监控每个执行者吗?