springboot webflux

函数式编程:

网上也没有清晰的定义,我个人理解函数式编程和非函数编程是这样的:有流相关的一些思想,并能运用到工作中,我们就可以说自己会函数式编程。

为什么要使用函数式编程?和命令式编程区别?

命令式编程你要告诉计算机怎样做,才能实现什么样的功能,但是在函数式编程里面你只需告诉计算机需要什么样的功能,具体怎样做不需要告诉他,不需要关注实现的细节

比如:找到最小值:

springboot webflux

你需要告诉程序怎样去比较才能找出最小的值,这样的编程叫命令式编程

用了函数式编程,直接java8就搞定了,个人认为函数式编程更多的是方法论上的一些东西

springboot webflux

如果数据比较多,需要并行处理,parallel()就行

springboot webflux

再比如创建一个线程

springboot webflux


Lambda表达式的方法引用:

当一个匿名的方法的方法体只有一行  参数 -> 具体的实现.

springboot webflux

更简单的可以这样写:方法的引用

springboot webfluxspringboot webflux


stream流编程

之前循环数据是用的for循环的外部迭代:

springboot webflux

外部迭代是串行的,流的话可以使用并行流,还可以使用短路操作,不需要等所有的都处理完,也可以从中间拿出来就行

中间操作、终止操作和惰性求值:

springboot webflux

惰性求值就是终止操作没有被调用的情况下中间操作不会被执行。如何判断:

看返回值返回的是一个流还是其他的,如果还是流就是中间操作,否则就是终止操作

springboot webflux

串行流:

springboot webflux

可以看出,是一行一行串行执行的,并行执行可以下面:

springboot webflux

这样就是在多线程的环境下打印

如何实现先并行执行后串行执行?多次调用,以最后一次为准,下面这样的还是串行执行

springboot webflux

pallerStream默认使用的线程池是jak8的ForkJoinPool.commonPool

springboot webflux

springboot webflux

如果都用默认的线程池,必然不可预知的会发生任务阻塞的情况,为了避免这种情况,可以自定义

springboot webflux

相关文章: