Method joinAll

ij/src/main/java/ij/util/ThreadUtil.java:128–148

Waits for completion of all Callable s corresponding to the Future s given. If the current thread is interrupted, each of the Callable s gets cancelled and interrupted. Also in that case, this method waits until all callables have finished. The 'interrupted'

(Future[] futures)

	 *  as required for preview in an ImageJ ExtendedPlugInFilter.
	 */
	public static void joinAll(Future[] futures) {
		boolean interrupted = false;
		for (int i=0; i<futures.length; i++) {
			Future f = futures[i];
			try {
				f.get();
			} catch (InterruptedException e) {
				interrupted = true;
				for (int j=i; j<futures.length; j++)
					futures[j].cancel(true);
				i--;  //we still have to wait for completion of this one
			} catch (CancellationException e) { //cancellation is allowed, e.g. during preview
			} catch (Exception eOther) {
				ij.IJ.log("Error in thread called by "+Thread.currentThread().getName()+":\n"+eOther);
			}
		}
		if (interrupted) {
			Thread.currentThread().interrupt();
			threadPoolExecutor.purge();
		}
	}
}