2021-06-16 forkjion stream流式计算方法

//求和计算任务
public class Demo01 extends RecursiveTask<Long> {private long start; //1private long end;     //1990900000//临界值private long temp = 10000L;public Demo01(long start, long end) {this.start = start;this.end = end;}//计算方法@Overrideprotected Long compute() {if ((end - start) < temp) {long sum = 0L;for (long i = start; i < end; i++) {sum += i;}return sum;} else {//分支合并计算 forkjoinlong middle = (start + end) / 2; //中间值Demo01 forkjoin1 = new Demo01(start, middle);forkjoin1.fork(); //拆分任务，把任务压入线程队列Demo01 forkjoin2 = new Demo01(middle+1, end);forkjoin2.fork();//拆分任务，把任务压入线程队列return forkjoin1.join() + forkjoin2.join();}}}

//大数据量的时候使用
public class Test369 {public static void main(String[] args) throws ExecutionException, InterruptedException {test01();test02();test03();}
//普通的public static void test01(){long sum = 0L;long start = System.currentTimeMillis();for (long i = 1; i < 10_0000_0000L; i++) {sum+=i;}long end = System.currentTimeMillis();System.out.println("sum="+sum+"时间： "+(end-start));}//使用forkjion的人员public static void test02() throws ExecutionException, InterruptedException {long start = System.currentTimeMillis();ForkJoinPool forkJoinPool = new ForkJoinPool();ForkJoinTask<Long> tast = new Demo01(0L, 10_0000_0000L);ForkJoinTask<Long> submit = forkJoinPool.submit(tast);//提交任务Long sum = submit.get();long end = System.currentTimeMillis();System.out.println("sum="+sum+"时间： "+(end-start));}//使用Stream计算的人员public static void test03(){long start = System.currentTimeMillis();//Stream 并行流//求和long sum = LongStream.rangeClosed(0L, 10_0000_0000).parallel().reduce(0, Long::sum);long end = System.currentTimeMillis();System.out.println("sum="+sum+"时间： "+(end-start));}
}

2021-06-16 forkjion stream流式计算方法相关推荐

JavaSE-常用类、Stream 流式计算
JavaSE-常用类.Stream 流式计算常用类内置包装类 Integer String 类型转换 StringBuilder(JDK1.5) StringBuffer(JDK1.0) Date ...
Lambda表达式和Stream流式编程
写在前面 IDEA都默认是jdk11了,我这还写着jdk8的新特性呢,惭愧惭愧.其实在学校的时候,基本没咋用过Lambda表达式和Stream流式编程,但是在实习的时候,发现公司的代码好多这样写的,没 ...
jdk8新特性（二）Stream流式操作
1.流处理过程 2.Stream流式分类 Stream,IntStream,LongStream,DoubleStream 3.操作符 Stream 的一系列操作必须要使用终止操作,否者整个数据流是不 ...
函数式接口和Stream流式思想
函数式接口和Stream 1. 函数式接口 1.1 函数式接口概述利用接口操作语法格式,对于方法的声明作出二次封装!!!方法声明:权限修饰符是否静态返回值类型方法名(形式参数列表);对于接口而 ...
JDK8新特性(三)：集合之 Stream 流式操作
1.Stream流由来首先我们应该知道:Stream流的出现,主要是用在集合的操作上.在我们日常的工作中,经常需要对集合中的元素进行相关操作.诸如:增加.删除.获取元素.遍历. 最典型的就是集合遍历 ...
Java stream流式计算详解
Java stream流式计算详解 1. Stream概述 1.1 Stream简介 1.2 Stream分类 2. Stream操作 2.1 Stream创建 2.2 Stream无状态操作 2.3 ...
Java8新特性之Stream流式编程
特地感谢鲁班大叔的分享,原学习地址:Java8 Stream流式编程爱撸码就是快,流式编程好代码传家宝以下是学习过程整理的笔记 1.简介 Stream 流处理,首先要澄清的是 java8 中的 ...
Stream流式计算
一.什么是Stream流式计算(学习此之前,要先知道四大函数式接口) 1.常用的集合是为了存储数集,而对于集合数据的一些处理(像筛选集合数据等)可以使用Stream流来处理 2.jav ...
java8/Stream流式计算从入门到精通/函数式编程实战
摘要:Stream流式计算,本文讲解了Stream流式计算的概念,具体的使用步骤以及源码实现,最后讲解了使用Stream过程中需要注意的事项.Stream在公司项目中被频繁使用,在性能优化上具有广泛的 ...
mysql流式计算,Stream流式计算
Stream流式计算什么是Stream流式计算数据处理中不可缺少的两部分:存储 + 计算集合.MySQL本质就是存储数据的,计算都应该交给流来操作! package com.kuang.stre ...

2021-06-16 forkjion stream流式计算方法

2021-06-16 forkjion stream流式计算方法相关推荐

最新文章

热门文章