package org.jimmy.test2019091701; import java.util.Arrays; import java.util.List; import java.util.Set; import java.util.concurrent.Callable; import java.util.concurrent.CompletionService; import java.util.concurrent.Executor; import java.util.concurrent.ExecutorCompletionService; import java.util.concurrent.Executors; import java.util.stream.Collectors; import java.util.stream.Stream; /** * @author YueShen * @date 2019年9月17日 下午5:48:33 * @detail */ public class Test { public static Executor executor = Executors.newFixedThreadPool(30); public static <T>List<T> forkJoin(List<Callable<T>> list){ CompletionService<T> service = new ExecutorCompletionService<T>(executor); list.forEach(service::submit); return Stream.generate(() -> 1).limit(list.size()).map(x -> { try{ return service.take().get(); }catch(Exception e){ } return null; }).collect(Collectors.toList()); } public static <T>List<T> forkJoin(Callable<T>... callables){ return forkJoin(Arrays.asList(callables)); } public static <T>Set<T> test(){ return null; } public static void main(String[] args) { List<Integer> numList = forkJoin(() -> -2, () -> -1, () -> 0, () -> -1 ); System.out.println(numList); numList = forkJoin(() -> 1 + 1, () -> 2 + 2); System.out.println(numList); } }
jdk1.8练习201909200843By:镜花水月(月神)
2015年10月-2016年3月 总计:5个月.
2016年11月-2017年6月 总计:7个月.
2017年7月-2018年4月 总计:9个月.
2018年5月-2018年5月 总计:1个月.
2018年6月-2018年12月 总计:6个月.
2019年1月-2019年12月 总计11个月.
2020年2月-2021年2月 总计13个月.
所有总计:5+7+9+1+6+11+13=52个月(4年4个月).
本人认同二元论.我是理想主义者,现实主义者,乐观主义者,有一定的完美主义倾向.不过,一直都是咸鱼(菜鸟),就算有机会,我也不想咸鱼翻身.(并不矛盾,因为具体情况具体分析)
英语,高等数学,考研,其他知识学习打卡交流QQ群:946556683
2016年11月-2017年6月 总计:7个月.
2017年7月-2018年4月 总计:9个月.
2018年5月-2018年5月 总计:1个月.
2018年6月-2018年12月 总计:6个月.
2019年1月-2019年12月 总计11个月.
2020年2月-2021年2月 总计13个月.
所有总计:5+7+9+1+6+11+13=52个月(4年4个月).
本人认同二元论.我是理想主义者,现实主义者,乐观主义者,有一定的完美主义倾向.不过,一直都是咸鱼(菜鸟),就算有机会,我也不想咸鱼翻身.(并不矛盾,因为具体情况具体分析)
英语,高等数学,考研,其他知识学习打卡交流QQ群:946556683