java8中forkjoin和optional框架使用

并行流与串行流

并行流就是把一个内容分成多个数据块，并用不同的线程分别处理每个数据块的流。

java 8 中将并行进行了优化，我们可以很容易的对数据进行并行操作。stream api 可以声明性地通过 parallel（）与 sequential（）在并行流与顺序流之间进行切换。

了解 fork/join 框架

fork/join 框架：就是在必要的情况下，将一个大任务，进形拆分（fork）成若干个小任务（拆到不可再拆时），再将一个个的小任务运行的结果进行join汇总。

fork/join 框架与传统线程池的区别：

采用“工作窃取”模式(work-stealing):

当执行新的任务时，它可以将其拆分成更小的任务执行，并将小任务加到线程队列中，然后再从一个随机线程的队列中偷一个并把它放在自己的队列中。

相对于一般的线程池实现,fork/join框架的优势体现在对其中包含的任务的处理方式上.在一般的线程池中,如果一个线程正在执行的任务由于某些原因无法继续运行,那么该线程会处于等待状态.而在fork/join框架实现中,如果某个子问题由于等待另外一个子问题的完成而无法继续运行.那么处理该子问题的线程会主动寻找其他尚未运行的子问题来执行.这种方式减少了线程的等待时间,提高了性能。

									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

									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);     

									  }

									}

									@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 + "]";

									  }

									}