扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
这篇文章将为大家详细讲解有关Java基于fork/koin类实现并发排序的示例,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。
创新互联服务项目包括宜都网站建设、宜都网站制作、宜都网页制作以及宜都网络营销策划等。多年来,我们专注于互联网行业,利用自身积累的技术优势、行业经验、深度合作伙伴关系等,向广大中小型企业、政府机构等提供互联网行业的解决方案,宜都网站推广取得了明显的社会效益与经济效益。目前,我们服务的客户以成都为中心已经辐射到宜都省份的部分城市,未来相信会继续扩大服务区域并继续获得客户的支持与信任!
概述
主要谈一谈 Java使用fork/koin类 实现的并发排序 以及对于Stream流的支持的splitetor
mismatch() -> 寻找两个数组 第一次出现数据不一致的下标
parallelPrefix() -> 对数组进行,累加求和
parallelSetAll() -> 对数组进行置数,
parallelSort() -> 并行排序
Spliterator() -> 对数组进行切分(切分后的数据为所有的数据的组合)
奇数 x/2+1 11->6
偶数 x/2 10 ==>5
public class Use_Arrays { @Test public void test_mismatch() { int []x =new int[] {1,2,3,4}; int []y =new int[] {1,3,4,5}; int index = Arrays.mismatch(x, y); System.out.println(index); } @Test public void test_parallelPrefix() { int []x =new int[] {1,2,3,4}; //f2=f1+f2 //f3=f2+f3 Arrays.parallelPrefix(x, (k,v)->k+v); System.out.println(Arrays.toString(x)); // 实现1-100累加求和 int []y =new int[100]; Arrays.parallelSetAll(y, k->k=1); Arrays.parallelPrefix(y, (k,v)->k+v); System.out.println(Arrays.toString(y)); } @Test public void test_parallelSetAll() { int []x =new int[100]; x[0]=1; Arrays.parallelSetAll(x, y->y+1); System.out.println(Arrays.toString(x)); } @Test public void test_parallSort() { IntStream stream = new Random().ints(0, 1000).limit(1000); int[] array = stream.toArray(); System.out.println(Arrays.toString(array)); Arrays.parallelSort(array); System.out.println(Arrays.toString(array)); } @Test public void test_spliterator() { int []x =new int[11]; Arrays.parallelSetAll(x, k->k+=1); System.out.println(Arrays.toString(x)); Spliterator.OfInt int0_100 = Arrays.spliterator(x); int [] y=new int[(int) int0_100.estimateSize()]; int i=0; System.out.println(int0_100.estimateSize()); System.out.println(int0_100.characteristics()); System.out.println(int0_100.getExactSizeIfKnown()); //spliterator.forEachRemaining((int k)->System.out.println(k)); OfInt int1_50 = int0_100.trySplit(); OfInt int2_25 = int1_50.trySplit(); int0_100.forEachRemaining((int k)->System.out.print(k+" ")); System.out.println(); int1_50.forEachRemaining((int k)->System.out.print(k+" ")); System.out.println(); int2_25.forEachRemaining((int k)->System.out.print(k+" ")); } }
2:使用Spliterator实现并行输出
@Test public void definied_Sort() { IntStream stream = new Random().ints(0, 100).limit(100); int[] array = stream.toArray(); Arrays.sort(array); final int NUMS=3;// 切分的次数 ExecutorService thread_pool = Executors.newFixedThreadPool(10); Spliterator.OfInt cut1 = Arrays.spliterator(array); while(!thread_pool.isTerminated()) { thread_pool.submit(()->{ OfInt split = cut1.trySplit(); thread_pool.shutdown(); split.forEachRemaining((int k)->System.out.print(k+" ")); System.out.println(); }); } }
Java的基本数据类型分为:1、整数类型,用来表示整数的数据类型。2、浮点类型,用来表示小数的数据类型。3、字符类型,字符类型的关键字是“char”。4、布尔类型,是表示逻辑值的基本数据类型。
关于“Java基于fork/koin类实现并发排序的示例”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,使各位可以学到更多知识,如果觉得文章不错,请把它分享出去让更多的人看到。
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流