我想最接近的事情是：
ExecutorService exec = Executors.newFixedThreadPool(SOME_NUM_OF_THREADS);
try {
for (final Object o : list) {
exec.submit(new Runnable() {
@Override
public void run() {
// do stuff with o.
}
});
}
} finally {
exec.shutdown();
}
根据TheLQ的意见，你可以将SUM_NUM_THREADS设置为Runtime.getRuntime()。availableProcessors();
编辑：决定添加一个基本的“Parallel.For”实现
public class Parallel {
private static final int NUM_CORES = Runtime.getRuntime().availableProcessors();
private static final ExecutorService forPool = Executors.newFixedThreadPool(NUM_CORES * 2, new NamedThreadFactory("Parallel.For"));
public static void For(final Iterable elements, final Operation operation) {
try {
// invokeAll blocks for us until all submitted tasks in the call complete
forPool.invokeAll(createCallables(elements, operation));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public static Collection> createCallables(final Iterable elements, final Operation operation) {
List> callables = new LinkedList>();
for (final T elem : elements) {
callables.add(new Callable() {
@Override
public Void call() {
operation.perform(elem);
return null;
}
});
}
return callables;
}
public static interface Operation {
public void perform(T pParameter);
}
}
Parallel.For的示例用法
// Collection of items to process in parallel
Collection elems = new LinkedList();
for (int i = 0; i < 40; ++i) {
elems.add(i);
}
Parallel.For(elems,
// The operation to perform with each item
new Parallel.Operation() {
public void perform(Integer param) {
System.out.println(param);
};
});
编辑
我把这个在GitHub如果有人有兴趣。 Parallel For on GitHub
