下面是一个demo：
public class TestThread {
private static int nThreads =Runtime.getRuntime().availableProcessors() * 2 + 1; //创建的线程数理论最优值是cpu核数的2n+1
private static ExecutorService executors = Executors.newFixedThreadPool(nThreads, new ThreadFactory() { //创建线程池
private final String threadNamePrefix="thread_name_task_";
private final AtomicInteger count = new AtomicInteger(1);//原子性操作，保证每个线程数值的安全性
@Override
public Thread newThread(Runnable r) {
Thread t = new Thread(Thread.currentThread().getThreadGroup(),r,threadNamePrefix + count.getAndIncrement());
t.setDaemon(true);
return t;
}
});
public static void main(String[] args) {
List<Future<String[]>> fList = new ArrayList<>();
for (int i = 0; i < 10; i++) {
final int nextInt = new Random().nextInt(100);
Future<String[]> f = executors.submit(new TestTask(nextInt));
fList.add(f);
}
/*for (Future<String[]> future : fList) {
try {
String [] result = future.get();
System.out.println(result[0] + " , 结果 " + result[1]);
} catch (InterruptedException e) {
} catch (ExecutionException e) {
}
}
System.out.println("main 线程结束 ");
}
static class TestTask implements Callable<String[]> {
private int i ;
public TestTask(int i){
this.i = i;
}
@Override
public String[] call() throws Exception {
String result = i%2 == 0 ? "S" : "F";
// 业务处理逻辑
//Thread.sleep(1000);
System.out.println(Thread.currentThread().getName() + "第" + i + "次任务");
return new String[] {Thread.currentThread().getName(),result};
}
}
}
线程异步执行结果：
