线程池多线程处理

public class TestExcel {

public static void main(String[] args) throws InterruptedException, ExecutionException {
ExecutorService executorPool = Executors.newFixedThreadPool(5);
List<Future<String>> resultArray = new ArrayList<Future<String>>();
final List<String> data = new ArrayList<String>();
for (int i = 0; i < 10; i++) {
data.add("我是第" + i + "条数据");
}
for (int i = 0; i < data.size(); i++) {
final String itemContent = data.get(i);
Future<String> result = executorPool.submit(new Callable<String>() {
@Override
public String call() throws Exception {
String doneContent = itemContent + "==========done";
return Thread.currentThread().getName() + doneContent;
}
});
resultArray.add(result);

if (resultArray.size() == 5) {
for (Future<String> f : resultArray) {
String res = null;

res = (String) f.get();

System.out.println(res);
}
resultArray.clear();
}
}
for (Future<String> f : resultArray) {
String res = (String) f.get();
System.out.println(res);
}

}
};

pool-1-thread-1我是第0条数据==========done
pool-1-thread-2我是第1条数据==========done
pool-1-thread-3我是第2条数据==========done
pool-1-thread-4我是第3条数据==========done
pool-1-thread-5我是第4条数据==========done
pool-1-thread-3我是第5条数据==========done
pool-1-thread-3我是第6条数据==========done
pool-1-thread-3我是第7条数据==========done
pool-1-thread-3我是第8条数据==========done
pool-1-thread-3我是第9条数据==========done

public class CallableAndFuture {

/**
* @param args
*/
public static void main(String[] args) {
ExecutorService threadPool2 = Executors.newFixedThreadPool(2);
CompletionService<String> completionService = new ExecutorCompletionService<String>(threadPool2);
for (int i = 1; i <= 10; i++) {
final int seq = i;
completionService.submit(new Callable<String>() {
@Override
public String call() throws Exception {
Thread.sleep(new Random().nextInt(5000));
for (int j = 0; j < 2; j++) {
Thread.sleep(1000);
}
return Thread.currentThread().getName() + seq;
}
});
}
for (int i = 0; i < 10; i++) {
try {
System.out.println(completionService.take().get());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (ExecutionException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}

pool-1-thread-1我是数据3
pool-1-thread-2我是数据3
pool-1-thread-1我是数据1
pool-1-thread-2我是数据4
pool-1-thread-1我是数据5
pool-1-thread-2我是数据7
pool-1-thread-1我是数据8
pool-1-thread-2我是数据6
pool-1-thread-1我是数据9
pool-1-thread-2我是数据10