newFixedThreadPool线程池的使用

@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;

    }

}