并行流与串行流
并行流就是把一个内容分成多个数据块，并用不同的线程分别处理每个数据块的流。
java 8 中将并行进行了优化，我们可以很容易的对数据进行并行操作。stream api 可以声明性地通过 parallel（）与 sequential（）在并行流与顺序流之间进行切换。
了解 fork/join 框架
fork/join 框架：就是在必要的情况下，将一个大任务，进形拆分（fork）成若干个小任务（拆到不可再拆时），再将一个个的小任务运行的结果进行join汇总。
fork/join 框架与传统线程池的区别：
采用“工作窃取”模式(work-stealing):
当执行新的任务时，它可以将其拆分成更小的任务执行，并将小任务加到线程队列中，然后再从一个随机线程的队列中偷一个并把它放在自己的队列中。
相对于一般的线程池实现,fork/join框架的优势体现在对其中包含的任务的处理方式上.在一般的线程池中,如果一个线程正在执行的任务由于某些原因无法继续运行,那么该线程会处于等待状态.而在fork/join框架实现中,如果某个子问题由于等待另外一个子问题的完成而无法继续运行.那么处理该子问题的线程会主动寻找其他尚未运行的子问题来执行.这种方式减少了线程的等待时间,提高了性能。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
|
import java.time.duration;
import java.time.instant;
import java.util.concurrent.forkjoinpool;
import java.util.concurrent.forkjointask;
import java.util.concurrent.recursivetask;
import java.util.stream.longstream;
public class testforkjoin {
public static void main(string[] xx){
}
private static void test1(){
instant start=instant.now();
forkjoinpool pool=new forkjoinpool();
forkjointask<long> task = new forkjoincalculate(0l, 10000000000l);
long sum = pool.invoke(task);
system.out.println(sum);
instant end=instant.now();
system.out.println("消耗时间"+duration.between(start, end).tomillis()+"ms");//消耗时间3409ms
}
private static void test2(){
instant start=instant.now();
long sum = longstream.rangeclosed(0l, 10000l)
.parallel()
.reduce(0,long::sum);
system.out.println(sum);
instant end=instant.now();
system.out.println("消耗时间" + duration.between(start, end).tomillis()+"ms");//消耗时间2418ms
}
}
class forkjoincalculate extends recursivetask<long>{
private static final long serialversionuid = 1234567890l;//序列号
private long start;
private long end;
private static final long threshold=2500000000l;//临界值
public forkjoincalculate(long start,long end) {
this.start=start;
this.end=end;
}
@override
protected long compute() {
long length = end - start;
if(length <= threshold){
long sum=0;
for(long i = start; i <= end; i++){
sum += i;
}
return sum;
}else{
long middle = (start+end)/2;
forkjoincalculate left = new forkjoincalculate(start, middle);
left.fork();
forkjoincalculate right=new forkjoincalculate(middle+1, end);
right.fork();
return left.join() + right.join();
}
}
}
|
optional类
optional< t>类(java.util.optional) 是一个容器类，代表一个值存在或不存在。
原来用null表示一个值不存在，现在 optional可以更好的表达这个概念。并且可以避免空指针异常。
常用方法：
optional.of(t t) : 创建一个 optional 实例
optional.empty() : 创建一个空的 optional 实例
optional.ofnullable(t t):若 t 不为 null,创建 optional 实例,否则创建空实例
ispresent() : 判断是否包含值
orelse(t t) : 如果调用对象包含值，返回该值，否则返回t
orelseget(supplier s) :如果调用对象包含值，返回该值，否则返回 s 获取的值
map(function f): 如果有值对其处理，并返回处理后的optional，否则返回 optional.empty()
flatmap(function mapper):与 map 类似，要求返回值必须是optional
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
public class optionaltest1 {
public static void main(string[] args){
string s = new string("ha");
// optional<string> op = optional.of(null);
//
// string s1 = op.get();
// system.out.println(s1);
// optional<string> op1 = optional.empty();
// string s1 = op1.get();
// system.out.println(s1);
optional<string> op1 = optional.ofnullable(null);
// system.out.println(op1.ispresent());
// system.out.println(op1.orelse(new string("google")));
//system.out.println(op1.orelseget(() -> new string("ali")));
optional<string> op2 = op1.map((x) -> x.tolowercase());
string s2 = op2.get();
system.out.println(s2);
}
}
|
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
@test
public void test5(){
man man=new man();
string name=getgodnessname(man);
system.out.println(name);
}
//需求：获取一个男人心中女神的名字
public string getgodnessname(man man){
if(man!=null){
godness g=man.getgod();
if(g!=null){
return g.getname();
}
}
return "苍老师";
}
//运用optional的实体类
@test
public void test6(){
optional<godness> godness=optional.ofnullable(new godness("林志玲"));
optional<newman> op=optional.ofnullable(new newman(godness));
string name=getgodnessname2(op);
system.out.println(name);
}
public string getgodnessname2(optional<newman> man){
return man.orelse(new newman())
.getgodness()
.orelse(new godness("苍老师"))
.getname();
}
//注意：optional 不能被序列化
public class newman {
private optional<godness> godness = optional.empty();
private godness god;
public optional<godness> getgod(){
return optional.of(god);
}
public newman() {
}
public newman(optional<godness> godness) {
this.godness = godness;
}
public optional<godness> getgodness() {
return godness;
}
public void setgodness(optional<godness> godness) {
this.godness = godness;
}
@override
public string tostring() {
return "newman [godness=" + godness + "]";
}
}
|
以上就是我们给大家整理的java8中forkjoin和optional框架使用心得的全部内容，大家在学习的时候如果还有任何不明白的地方可以在下方的留言区讨论。
原文链接：https://my.oschina.net/u/3746673/blog/1594197
相关文章
