在实际业务开发过程中，我们需要使用多线程，高并发执行某个业务逻辑方法，方法的请求参数是实体类，返回参数也是实体类，本文将介绍如何实现此功能。

详情参见下面代码，由于为了方便演示，两个实体类和业务方法都放在了main方法所在的类，所以加了static修饰符。

public class TestThread {
    public static void main(String[] args) {

        List<Input> inputList = new ArrayList<>();

        //首先我们构造一个请求参数的集合
        for (int i = 0; i < 50; i++) {
            Input input = new Input();
            input.setNameInput("集合信息" + i);
            inputList.add(input);
        }

        // 创建一个线程大小与集合数量相等的线程池
        ExecutorService pool = Executors.newFixedThreadPool(inputList.size());

        // 创建Future的list集合，用以接收返回值
        List<Future> list = new ArrayList();

        for (int i = 0; i < inputList.size(); i++) {
            //请求实体类
            Input input = inputList.get(i);
            // 执行任务并获取Future对象，这里采用lambda表达式替代Callable接口的实现
            // getName(input)就是你要执行业务逻辑的方法，返回值需要用f.get()获取
            Future f = pool.submit(() -> getName(input));
            list.add(f);
        }
        // 关闭线程池
        pool.shutdown();

        // 循环获取所有并发线程的任务结果
        for (Future f : list) {

            try {
                // 从Future对象上获取任务的返回值，返回一个实体类,需要进行强制转换
                //f.get()会一直阻塞主进程，直到业务逻辑方法执行结束
                Output output = (Output) f.get();

                //我们输出一下看看结果
                System.out.println("output结果："+output.getNameOutput());
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }

        }

    }

    /**
     * 请求实体类
     */
    public static class Input {
        private String nameInput;


        public String getNameInput() {
            return nameInput;
        }

        public void setNameInput(String nameInput) {
            this.nameInput = nameInput;
        }
    }

    /**
     * 返回实体类
     */
    public static class Output {
        private String nameOutput;


        public String getNameOutput() {
            return nameOutput;
        }

        public void setNameOutput(String nameOutput) {
            this.nameOutput = nameOutput;
        }
    }

    /**
     * 你的业务逻辑方法
     * @param input 请求实体类参数
     * @return 返回实体类参数
     */
    public static Output getName(Input input) {


        //为了证明我们的确开启了多线程，所以此处加了沉睡1秒钟的操作，50次循环在5秒钟内执行完毕，证明的确开启了多线程
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        Output output = new Output();
        //方法执行逻辑,我们这里只是将请求参数的nameInput赋值给返回参数的nameOutput
        output.setNameOutput(input.getNameInput());

        //返回
        return output;
    }
}