多线程学习一CompletableFutureDemo使用

package ThreadDemo;


import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.*;
import java.util.function.Function;
import java.util.stream.Collectors;


import lombok.var;
import org.apache.poi.ss.formula.functions.T;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

import com.alibaba.fastjson.JSON;
import com.google.common.collect.Lists;


public class CompletableFutureDemo {
    private static final ExecutorService THREAD_POOL_EXECUTOR = new ThreadPoolExecutor(10, 10, 60L,
            TimeUnit.SECONDS, new linkedBlockingQueue(100000));
    public static void main(String[] args) {
        CompletableFutureDemo completableFutureDemo=new CompletableFutureDemo();

        Listlist=new ArrayList<>();
        list.add(999);
        list.add(3);
        list.add(2);
        list.add(3);
        list.add(4);
        list.add(5);
        list.add(6);
        list.add(7);
        list.add(8);
        list.add(9);



    List future2 =  completableFutureDemo.invokeAsyncForList(list,getF(list));


//        CompletableFuture future2 = new CompletableFuture();
        Integer result = (Integer) future2.get(0);
        System.out.println(result);
        Integer result2 = (Integer) future2.get(1);
        System.out.println(result);
        Integer result3 = (Integer) future2.get(2);
        System.out.println(result);
        Integer result4 = (Integer) future2.get(3);
        System.out.println(result);


    }



    public static Function,List> getF(List integers){
        return t->{
            System.out.println(integers.size());
            return Collections.singletonList(t.stream().reduce(Integer::sum).orElse(0));
        };
    };


    public  List invokeAsyncForList(List params, Function, List> function){
        List resultList = Lists.newArrayList();
        //按指定长度 进行切分
        List> paramList = Lists.partition(params,2);
        System.out.println(paramList.size());
        try{
            List>> futureList = paramList
                    .stream()
                    .map(pa -> CompletableFuture.supplyAsync(() -> function.apply(pa) ,THREAD_POOL_EXECUTOR))
                    .collect(Collectors.toList());

            List> joinList = futureList.stream().map(CompletableFuture::join).collect(Collectors.toList());
            joinList.stream().forEach(System.out::println);
            joinList.stream().forEach(resultList::addAll);
        }catch (Exception e) {
            System.out.println(e.getMessage());
        }

        return resultList;
    }
}