java.util.concurrent 多线程处理list

public static void main(String[] args) {
try {
List<Department> list = new ArrayList<Department>();
for (int d = 0; d < 10; d++) {
Department department = new Department();
List<Person> personList = new ArrayList<Person>();
for (int i = 0; i < 3; i++) {
Person person = new Person();
person.setName("name" + "_" + d + "_" + i);
person.setSex((i % 2 == 0) ? "boy" : "girl");
person.setAge(i + "");
personList.add(person);
}
department.setName("deparName" + d);
department.setPersonList(personList);
list.add(department);
}

} catch (Exception e) {
e.printStackTrace();
}

testLogger();
}

public static void formatList(List<Department> list, final int nThreads)
throws Exception {
if (list == null || list.isEmpty()) {
return;
}

StringBuffer ret = new StringBuffer();

int size = list.size();
ExecutorService executorService = Executors
.newFixedThreadPool(nThreads);
List<Future<List<Department>>> futures = new ArrayList<Future<List<Department>>>(
nThreads);

for (int i = 0; i < nThreads; i++) {
final List<Department> subList = list.subList(size / nThreads * i,
size / nThreads * (i + 1));
initLog4j(i+"");
Callable<List<Department>> task = new Callable<List<Department>>() {
@Override
public List<Department> call() throws Exception {
StringBuffer sb = new StringBuffer();
for (Department department : subList) {
List<Person> personList = department.getPersonList();
for (Person person : personList) {
person.setSex("sex" + person.getSex());
logger.info(person.getName());
}
}
return subList;
}
};
futures.add(executorService.submit(task));
}

for (Future<List<Department>> future : futures) {
List<Department> newList = future.get();
for (Department department : newList) {
for (Person person : department.getPersonList()) {
System.out.println(person.getName() + " : "
+ person.getSex());
}
}
}
executorService.shutdown();

return;
}