@RestController
public class DemoController {
public static void main(String[] args) {
List strs =new ArrayList<>();
getStrs(strs);
System.out.println("strs = " + strs);
}
public static void getStrs(List strs){
List> list =new ArrayList<>();
ExecutorService service =null;
try {
service = Executors.newFixedThreadPool(5);
for (int i =0; i <5; i++) {
Future future = service.submit(new AbcCallable("a" + i, service.getClass().getName()));
list.add(future);
}
for (Future future : list) {
try {
strs.add(future.get());
}catch (Exception e) {
e.printStackTrace();
}
}
}catch (Exception e) {
e.printStackTrace();
}finally {
service.shutdown();
}
}
}
public class AbcCallableimplements Callable {
private Stringname;
private StringthreadName;
public AbcCallable(String name, String threadName) {
this.name = name;
this.threadName = threadName;
}
@Override
public String call()throws Exception {
System.out.println("name = " +name +": threadName = " +threadName);
return name;
}
}
