stream流式编程的好处

家伙八中提供了死追母流，他可以对集合进行操作，可执行复杂的查找、过滤、驱虫、排序等操作。 今天给大家分享两块，第一呢是 stream 流，对立斯特的便利过滤，查询驱虫和排序。第二部分呢是 stream 流的调试，看一下代码视力， 这里有一个学生集合，接下来呢，通过几个需求对 stream 进行一下了解。首先呢，便利集合，打印学生数据，查询高三的同学，这里呢，咱们可以通过 filter 进行过滤，然后过滤班级等于高三的。 这里有一点注意的是， filter 是个中间操作，他返回的是个新的流，所以说咱们需要将流转换成集合，查询学生张三的信息。这里呢，第一步先是过滤，过滤出姓名等于张三的。接下来呢，咱们通过 fund first 返回列表中的第一条数据。这里呢， 需要注意一点， fund first 和 fundini 呢，都是查找第一个元素，但是呢， fundini 只有在串形情况下，它返回的是第一个元素，如果并行的话，它是一个随机的元素。获取年机信息，首先呢，咱们需要根据年机将 list 转换成脉搏， 然后调用 distinct 方法就可以获取到对应的年级信息。根据学生年龄进行排序，这里呢，咱们调用 stream 的 soti 的方法， 然后根据学生的年龄进行排序，这里呢是升序的，如果是降序呢，需要教调用 reverse 的方法。根据年级进行分组，咱们通过格尔沃拜对年级进行分组，最终呢是返回一个 map 类型的集合。最后咱们看一下 stream 的调试，这里呢，咱们选择根据学生年龄排序进行调试， 这里可以看到一个追踪当前流的调用链，咱们点击完成之后呢，会看到整个调用的过程还是比较方便的。最后小伙伴们在工作中还用到了哪些 stream 的操作？评论区分享一下。

哈喽，之前跟大家分享过了一个关于 stream 流和拉姆达表达式以及函数值接口的视频，然后呢有的小伙伴就在评论区留言说用 stream 流的这种形式啊，就是编码一时爽，然后调试火葬场， 那真的是这样吗？那我今天呢就跟大家分享一个代码的调试神器啊，比如说我们来看这样的一个代码，我们先把这样的一串数字啊，放到 off 这样的一个啊参数里面，然后呢我们去过滤，过滤出大于十的一个数，然后呢我们再把它映射成乘幺，就是映射成一个两倍 啊，然后呢我们再给他去除，再排序，再转换成数组，那如果说你用平时复循环的一种写法呢，他可能就会有很多层的一个欠套，对吧？那如果是用流的一种写法呢，一行简单的这样的一个代码我们就可以实现，那我们来调试一下，那那些说调试火葬场的一个小伙伴啊，就是意思 就是说我们用 skin 流的这种写法呢，我们没有办法看到他每一步的一个变化是什么样子的，那真的是这样吗？我们来点 bug 一下，点 bug 之后呢，我们会看到这边有一个这个按钮， 这个，然后呢我们点击一下，那我们来看一下啊，那这边呢就是我们的一个原数字，那我们点一下 future， 那他这边呢就会自动的给我们筛选出大于十的一个数字，我们再来点一下 map， 他就会自动的给我们那个数，呃，那些数字呢给他乘以二，然后我们再去重，然后我们再去排序， 排序之后呢他就会给我们按照一个顺序排列，最终呢我们转成数组，那其实我们这样每一步的一个执行过程我们都能够去啊，看的非常的清楚，是不是很方便呢？那所以呢，我并不是很赞同他们的一些说法， 工作很多年的一些程序员呢，他们都不愿意用一些 string 流的一些写法去写，那其实我觉得作为一个程序员，我们就应该不断的去拥抱变化，对吧？然后呢不断的去提升自己，不断的学习。大家如果说想要我之前的一些 demo 的话呢，可以到这边来 这边，然后呢给他去发一个消息，像这样就可以拿到我们的一个 demo。 好，今天的一个分享就到这。

好，那么接下来呢，我们就开始学习扎尔巴推出的另外一个核心叫做 stream api， 那么对于扎尔巴来讲，两大核心，一个就是拉姆达表达式，那么另外一个就是现在这个叫做强大的 stream api， 那么拉姆达加上这个 stream api， 我们就可以向 啊斯尔口一样去操作我们账号中的数据，我们学学就知道了。那么什么是死菌 ma api 呢？我们首先得先了解一下，对吧？我们说 两大核心对吧，一个是拉布达表达是，另外一个就是这个 steamapi， 也就是说在扎巴点 uto 包下，又多了个 steam 包，下边的一些给我们提供的一些内裤供我们使用。那么呢， steam 大家之前是不是接触过 steam？ 是不是要留的概念呢？是不是留的概念？咱， 咱们在 i o 流中是不是学过了解过 stream 啊？哎，但是呢，我们说，虽然说一提到这个 stream 流的概念，大家就知道啊，它是处理数据的一种方式，那么这个处理数据呢？跟咱们之前那个 i o 流啊，处理数据方式很类似， 但是呢，略有一点不同的地方，那么什么是这个 steam 呢？他也是处理数据的，听懂吧？哎，都是处理数据的，什么这个呃 i， 无论是咱们之前学的 i o 流也好啊， 还是比如说咱们平时了解的这个多媒体流也好啊，还是现在的这个啊 stream 啊，就是这个张二八出的这个 stream 啊，流也好啊，实际上我们知道这个流啊，他都是处理数据的啊，那么我们就来一个这个画的画的像一点点啊，画的像 上一点点啊，都是这个处理数据，那么我们说了，只要想要处理数据，那是不都得建立一个用于传入数据的管道啊？实际上是一样的，那么我们张二八中的这个 stream 呢？你也处理数据，那既然要处理数据啊，他就得有一个叫做数据 源，听到吗？要想处理数据，他就得有一个数据源，那么在我们这里数据源是啥呢？要么是集合，要么是数组等等啊？数据源可以是集合，可以是数组， 可以是集合，可以是数组等等。然后接下来我们有了这个数据员，也就是有了数据之后，我们是不是该，对吧？完成这些数据的传输啊？要想完成数据的传输，你是不是也得建立一个用于传输数据的管道啊？其实是很累。 是的，但是大家注意咱们这个张二八中的这个 steam 啊，他在在对于数据的处理上，在这之间呢，他可以做一系列流水线式的中间操作啊，可以有 一系列叫做流水线，是流水线，是的中间操作，在这个传输的过程中， 可以完成一系列流水线式的中间操作，比如说我们对这些数据过滤呀，映射呀，切片呐等等等等。一系列流水线式的 这个中间操作之后，他注意最终产生一个全新的流，他是产生一个新的流，跟原来你的数据源呢，是 没有任何关系的，听懂吧？哎，就是数据流吗？流的概念都是数操作数据，原来的 i o 流，是啊，多媒体流，是现在咱们这个 steam apex steam 这个流也是操作数据的，只不过不同的地方在于，我们首先得有个数据源，数据源此时是集合或者是数组， 原来咱们的数据是不可以是一些文件、图片、视频、音频等等啊？现在的数据员可以是啊，集合或者是数组等等啊，都是用于纯数据的。然后紧接着呢， 我们会对这个数据源把它转换成流，转换成流了以后，我们可以在这个流之间做一系列流水线式的中间操作，也就是说对这些数据进行处理。但是不同的地方在于，对吧？处理了之后啊，他产生了一个全新的 流，跟我们原来的数据源是完全没有关系的。听懂这意思吧，就如同原来咱们做个文件的复制是不是也一样啊？比如说我把这个文件我复制一份，复制成一个新的文件，我改变原来新的文件，对原来新文件进行处理，原文件是不是并不会受影响？ 朋友们，哎，所以说流的概念呢，都是对于数据的一些操作，所以说通过这个我们能了解什么呢？ 了解到什么呢？说流，他到底是啥呀？实际上集合讲究的是数据，那么流讲究的是 计算啊，对数据进行一系列流水线式的中间操作以后，产生一个全新的流，对应的也就是全新的数据，而跟原来的数据源是没有任何关系的， 听懂吧。哎，所以说死俊吗？自己是不会存储元素的，死俊不会改变原对象，相反他们会返回一个持有结果全新的流。 然后呢， steam 操作是延迟，这个延迟呢，咱们一会再给大家说什么叫做延迟？好吧，哎，那这就是流。那么在这个张二发中啊，使用这个 steam 呢，只有三步，第一步，我们得创建一个流，对吧？哎，就是通过一个数据员，要么是集合，要么是数组获得一个流， 拿到了这个流，我们就可以进行一系列流水线式的中间操作啊，然后有了这个中间操作，对这些数据进行处理了以后，我们会啊，来个终止操作，或者也叫做终端操作，然后产生一个全新的结果啊，也就是你有个数据员，对吧？我要 把它转换成流，转换成流了以后，我们可以过滤呀，映射呀，切片呐等等等等一系列流水线似的中间操作，然后利用一个中指操作，产生我们所需要的结果，所以说整个流的使用就围绕这三步即可， 听懂这意思吧，哎，怎么过来啊？我们就一步一步来吧，不就一共三步吗？一步一步来，叫 stream api test 一吧。 说呀，对于流的操作一共就三步，对吧？关于流的操作，流的操作呀，就三步，第一步，那就是创建一个流，通过数据源创建一个流。 第二步呢，那就是一系列流水线式的中间操作，最后呢再来个中指操作操作，然后得到一个最终 结果。那么咱们先说第一个，我们该如何去获得一个流，或者叫创建一个流呢？ 叫做创建流。那么创建流的方式啊，人家给我们提供了四种方式，这我们是不是必须会啊？那么第一种方式呢，就是通过叫 conlax 是不集合呀？ conlax 系列集合提供的一个方法就叫做 stream 方法啊， 就可以获得可以创建一个流了，当然他还有一个方法，还有个方法也可以叫做 parallel p a， r， a， l， e， l， 对吧？ stream， stream， 那么这个方法呢，获得的是一个 并行流，前面这个方法获得的是一个串行流，并行流咱们之前是不是介绍过了呀？对吧？底层使用的是 foculate 框架 对吧？采用的是工作窃取名模式，说白了就是这是个单线层的流，这是个多线层的流，听懂吗？嗯，就这么个意思。 然后呢，那么我们就可以试一下啊，那比如说我们现在啊，有一个集合叫 list new， 一个 release， 当然集合中是不是有可能有数据啊？那么此时你只需要 list 点 stream， 这样的话就获得了一个流了， 这样就拿到了一个流，听懂吧？当然有了这个流，接下来我们就可以对这个流中数据进行一系列操作，然后得到结果。当然咱们是不是得一步一步学啊？后两步还没有呢，听懂吧？哎，咱们先说怎么去获取一个流， 搞定吧。哎，那这是第一种方式，通过 connection 系列集合的 stream 方法。 connection 系列集合是不是都有啊？正儿八经出的新方法，好吧， 卡莱克这里边有 list 系列集合有吧，赛特系列集合是不是也得有啊？都有。那么第二种方式呢，是通过 arist arise 类中的类中的一个，叫做 stream 方法。 stream 方法也可以创建一个数母流， 创建一个数组流，那么就搞一个数组吧，一个 integer 的数组，用一个 integr 的数组，比如说长度是十，对吧？然后呢，通过 arrays 点叫 stream stream 啊，然后呢，将这个 array 这个数组呢，把它转换成 流，然后有了这个流，我们就可以后续中间操作，中指操作了啊，叫做啊， arrays 的一个 stream 方法， ok， 那么第三种 方式是什么呢？通过通过 stream， stream 类中的 stream 类中的一个叫做 up 方法，也可以获取个流啊，并且它这个静态方法 stream 点 up， 大家注意看，这里边是不是叫做可变参数啊？可变参数实际上底层是不是也是数组啊？ 对吧？可不用参数，那么你这里边就可以来一个，比如说 a， a 呀， b， b 呀，这里边数据你是不是随便写呀， c， c 呀，然后 d， d， d 呀，等等啊，他这样的话呢，也会得到一个 流，拿到了流之后，我们又可以做一系列流水线式的中间操作啊，也就是说白了，针对数据进行一系列操作，最后产生一个你所需要的结果啊，利用这个终止操作搞定吧。嗯，那么还有第四种，第四种， 第四种呢，那叫做创建，可以创建无限流，无限流，什么叫无限呢？无限啥意思？ 无穷无尽对吧？哎，你可以创建无限流。那么创建无限流的方式有两种，第一种呢，又称之为叫做迭代啊，叫做迭代，迭代怎么做呢？也是通过 stream 类中提供了一个方法，这个方法叫做 iterate， iterate 方法，然后呢，这里边需要两个三数，第一个是不是带范型，范型的种子啊？后边这个叫做 ulnery operator， yunnery operator 什么意思， 对吧？比如说 univer operator， univery operator， 不知道，那就看一下用 a r y unori operator 啊，这个注意看，明显是不是用 j d， k 一点八出的一个叫做函数式接口 手啊，说白了 o univer， 翻译过来大家也大概猜到了，这叫一元运算吧，叫一元运算，然后你看，哎，这里头好像没写，没写是啥意思呢？看他继承了 function， 是不是要继承了方格身呢？然后给方格身指定了两个都是 t 啊，他这里是不是声明个 t， 然后呢？继承了方格身，两个都是 t， 什么意思呢？就是说你传进去的是个 t， 返回值也是个 t， 也就是传进去的是一个值，返回的值是相同类型的， 那是不就一元运算呢？对那个值进行一个一元运算的操作，那现在让你实现这个接口中的这个抽象方法能不能实现呢？传进去一个参数，返回的是一个同一个类型的值， 嗯，那么什么意思呢？前面个种子，种子说白了呢，就是一个起始值，然后边呢一元运算， 对吧？啊？比如说我来个 x 吧，然后我想对他进行什么操作呢？比如说 x 加二的这么一个操作，这样的话呢，他会给我们产生一个流啊，产生个流， 那么当然现在呢，我们创建了流，接下来我们是不是可以对这些数据做一些中间操作，终止操作呀？当然这俩操作咱们还没学，那么现在呢，为了让大家看一个结果，咱们来个终止操作，看看结果，好吧。啊？什么是终止操作呢？比如说 stream， 四点 foe h 啊，这叫便利，然后呢，我们说要把这个流里边的内容啊给打印输出，那么其实这个呢，叫做终止操作， 听到吗？这叫终止操作，那么接下来就看看这里边有什么效果吧，右键运行， 注意看他是不是在不断的产生，这，这无限吗？哎呦呵，我这一停他不让我看呢，啊，这呢，对吧？哎 啊，他还能给我回放啊，我，我已经停了，注意看他是不是产生的是偶数啊，不断的产生偶数， 从起始我这个种子开始，然后呢，从这个起始值开始不断的做加二的操作，那说白了就是无限的生成偶数，那这个就叫做迭代，那比如说你现在嫌他太多了，我们也可以来点中间操作，听懂吧？可以来点中间操作， 什么中间操作呢？比如说来个使劲点上 limit， 别蹭成那么多了，我 limit 就是说我取十个，但是这还没学呢，咱们先感受一下 这点，他就能不能让我对齐呀，我看着好别扭啊， ok， 对吧？那这个呢，叫做中间 操作，也就是上边我们创建了一个无限流，然后呢，我要取十个，别让他无，永远无限下去，这叫中间操作，然后利用中指操作，做一个什么操作呢？我要把这些数据打印输出啊，就是有结果了啊，让大家感受一下右键运行，那是不就十个呀？ 哎，产生了十个从零种子零开始的十个偶数啊，那这样的话就创建了一个无限零， 那么创建无限流还有第二个，那叫啥呢？叫做生成，叫生成。那么还是通过 stream 一个方法叫做 generate 啊， generator 方法参数需要个 splat， splat 咱们是不是已经非常熟悉了？这是 是一个供给型接口，它里边的抽奖方法是无参，但有返回值吧。无参有返回值，那就无限生成呗。无限生成啥呢？ mas random， random， 是不是静态方法呀？无限生成随机数产生一个新流， 可以吧？哎，无限的产生一个随机数。嗯，那么当然咱们现在也想先先先看结果的话，是不是先来一个终止操作呀？点 alt 冒号，冒号 carrink like 右键运行，看下效果。 这是不是无限的产生 double 啊，对吧？哎，无限的产生随机数啊。 ok， 那么接下来呢，我不想让他产生那么多，我也可以给他来一个，对吧？点 limit 中指操作产生 五个吧，然后再去 foes 打印输出。上面这个刚才是不是也也也生成了啊？生成了十个啊？没没没，没关系 啊，当然上面呢是利用这个，呃，迭代生成的十个偶数。下边呢，是利用这个第二种生成的无限流，生成了多少个呢？生成了五个大于等于零点零，小于一点零的随机 w。 好吧，行了，那么以上呢，就是创建流的四种方式，那么有了流之后，接下来流实际上对应的是不是就是你数据原中的数据啊？接下来说白了，我们就可以对数据进行 一系列处理，好吧，行，先把这四个操作，呃，这个熟悉一下。

接下来我们继续来学习死吹牛的常见中间操作来看这里，这一次我们学习这样的两个方法，一个是 mimit， 一个是 st， 因为他这个方法他是返回此瘤中的元素组成的瘤，截取前指定参数个数的数据，也就是他指定的一个参数，他是截取这个瘤中的一部分数据，他指定是前几个，那么这个 stele 他是 跳过指定参数个数的数据，返回由该流的剩余元素组成的流。那么接下来我们把这两个方法到程序中去演示一下。来看这里 我新建好了一个类，在这个类里面有这两个方法的注视信息。我们再来看我创建的一个集合，存储了多个资本上元素。接着我们来看需求，一， 取前三个数据在控制台输出，这里我们直接使用死吹母牛的方式来实现，那么首先是累死他， 点死去母方法得到死去母牛，然后这一次我们要调用这个前三个，我们用这个 limt 来限制一下三，就是前三个，然后把这数据在控制台输出，那就是 fex， c 层点 out， 然后来个引用预算服否认特烂。来看一下啊，右键执行 是不是把前三个在控制在输出了。林青霞，张曼玉，王祖贤啊，那这个方法就是取前几个的非常的好用。那么接着我们再来看跳过三个元素， 把剩下的元素在控制台输出，也就是说我拿到这个绿色集合所对应的四川母牛，跳过这 三个，把剩下的在控制台输出来，我们看一下啊， list 点四寸 d r skep 啊，这里我们写个三，再点 fex， 然后是 c 三点二，奥特，来个引用，预算服否认太烂。那么在这里我来个 slt， 回车，一二三四五六七八，给他隔开一下啊，看一下啊，右键执行。 那么这一次我们是从这个柳岩开始输出的，柳岩，张敏，张无忌，他跳过了三个，那么这就是这个 step 方法的使用。 接着我们再来看需求三，跳过两个元素，把剩下的元素中的前两个在控制台输出来看一下啊。这一次我们要做的操作是这样的，是 list， 点 steam， 先跳过两个是 steple， 接着把剩下的他的前两个，那就是 limat， 限制一下这两个，再 点佛一尺，在控制台输出来看一下啊，跳过两个，把剩下的这些里面的前两个在控制台输出，也就是王祖贤和柳岩，来看一下是不是这样的右键执行，看一下控制他的输出。 王祖贤，柳岩，没有问题吧。好嘞，到这，关于这个 limit 和 cap 方法我们就讲完了。

这段代码你们觉得应该怎么调试呢？这是加了吧的这个流操作， stream 的流操作。这种代码其实日常我们调试的时候很难调试啊，基本上调试不了，你蹲在这也没有用，对吧？今天我教大家一招啊， 我们可以随便端在这，或者是端在其中的某一行都可以啊。我们把断点调试集中起来，然后你们看到这个标志没有？ 点击，哎，看到了吗？这是初始状态，然后这是你的 fute， 对照一下做的 fut 的操作，然后他进行一个迈步， 最后形成的最终的一个结合，然后这底下还有一个 flag model， 一个扁平模式，可以一目了然吧？一目了然 一共多少个集合？他是怎么变化的？变化以后他进行迈步的转换，最后再进行一个呃，最终的一个集合，嗯，这样就很清晰的变换的一个查看了，你学会了吗？

本文将带你领略 java 八引入的 three vpi 的强大之处，包括如何利用中间操作和终端操作简化数据处理流程，以及如何利用并行流实现高效的并发编程。 在 java 八中， three mapi 作为一种革命性的新特性，不仅集大地提升了代码的可读性和简洁性，还为开发者提供了强大的并行处理能力。他以函数式编程的理念为核心，将集合处理转化为一系列连续的操作， 使得数据处理如同水流般顺畅且高效。首先，我们深入了解 stream api 的基本概念。一个 stream 是一个延迟执行的序列，它可以是集合数组、 i o 通道等源头生成，也可以由其他 stream 产生。通过调用流的 空间方法，如 map filter， sorted 等，我们可以对数据进行各种转换和筛选，而无需预先加在所有元素到内存中。这在处理大量数据时尤为重要，因为它可以节省内存资源。 中间操作允许我们在不实际计算结果的情况下对数据进行一系列操作。例如， map 用于将每个元素映射到另一个值， filter 则用于根据条件选择元素， 而 sort 则用于对元素进行排序。这些操作都是惰性的，只有当真正需要获取结果时才会触发计算。终端操作则是那些必须进行求职的操作， 比如， collect 用于收集结果到一个容器中， reduce 用于对所有元素进行累积计算， count 用于统计元素个数。这些操作会触发整个 stream 的执行并返回最终的结果。然而， javabard stream api 并不仅仅局限于单线程操作，通过并行流 parallel stream 功能， 我们可以在多核处理器上进行数据处理及大地提高了性能。并行流内部会自动将任务分割分配给不同的 cpu 核心执行，然后合并结果。但需要注意的是，虽然并行处理能提升效率， 但也需谨慎使用，因为过多的并行任务可能会导致上下文切换频繁，反而降低性能。此外，为了更好的控制并行流的行为，只要八八提供了诸如 norder 无序执行、适合数据无依赖的场景、 segrettel 强 强制顺序执行等方法，以及 parallelism 设置并发读属性，让开发者可以根据具体需求灵活调整。总的来说， javabutt stream api 是现代并行处理的艺术，它通过优雅的 api 和智能的内部优化， 帮助我们以简洁高效的方式处理数据，无论是单线程还是并行环境都能游刃有余。掌握这一工具无疑会使你的只要把编程生涯更加得心应手。

接下来我们来学习死吹母牛的生成方式，在讲解这个生成方式之前，首先我们来回顾一下体验死吹母牛的过程。 这里我有一个集合，这个集合中有一些数据，我们可以通过这个集合生成一个流，生成的流之后接下来我们通过 falt 来过滤一张开头的，我们就得到了一张开头的数据。再接下来我们通过 flt 过滤长度为三的，我们就得到了长度为三的数据。那么 最后我们通过说一起来指定我们对这些数据进行的操作，就是 sutm 点 out 点，不让他烂，把这些数据在控制台输出。 那么在这个过程中我们刚才说到了三种操作，一种是生成流的操作，一种是中间的过滤操作，最后 是我们在控制台输出的操作，那么在这里我们说一下我们此车美流的使用，它是分为三种操作的，一种是生成流的操作，一种叫中间操作，一种叫终结操作。来 我们说一下此吹母牛的使用，它分为生成牛、中间操作和终结操作。我们先来看生成牛，他是通过数据源集合或者数组等生成牛，比如说我们通过这个集合 act 点 steam， 也就是我们开始定的是个奥瑞利斯塔嘛，这个集合他的变量名叫做利斯塔，我通过这个集合调一个四十五方法就能够生成一个流，中间操作， 一个流后面可以跟零个或者多个中间操作，其目的主要是打开流，做出某种程度的数据过滤或者映射，然后返回一个新的流，交给下一个操作使用。比如说我们不要 方法，他就可以用来进行中间操作，他操作完之后还是一个死水目流。最后我们来说终结操作，一个流只能有一个终结操作，当这个操作执行后，流就被选光了，无法再被操作，所以这必定是流的最后一个操作，比如说这个 fex 方法，他就是用来为数据 指定对应的操作的，他是一个终结操作。好了，知道了我们死吹美流的这三种使用之后，接下来我们讲解第一种使用就是生成流，我们死吹美流的生成方式有很多种，这里我们讲解三种常见的生成方式。先来看第一种就是 可耐克人体系的集合，可以使用默认方法 steame 来生成流，注意这说的是可来客人体系的集合。那么第二种是迈普体系的集合，他不能直接生成流， 他只能间接的生成流，一会我们再去演示。第三个就是数组，可以通过 steam 这个接口中的静态方法来生成流，看这里 这个方法是一个可变参数的，他当然可以传一个数组了。好了，知道了这三种常见的生成方式之后，接下来我们到程序中去演示一下。 来看这里我新建好了一个包，在这个包下建好了一个类，在这个类里面有死垂母瘤常见的三种生成方式，注视信息。接下来我们先来演示。第 一个可耐克人体系集合来生成四川母牛，那么这里我们直接来一个利斯特吧，利斯特斯脆，利斯特，又一个奥瑞利斯特，那么这里写个斯脆。 接着我们 list 调用一个死去母方法，看出 ltv 生成，左边的内容，给他起个名字就叫 list 死去母。 接着我们再来一个赛特集合，死去赛特，又一个哈西赛特，这里写一个死去， 然后赛特点死去掉这个方法。 ctrl alt a 生成左边的内容，给他起个名字叫赛特死去。 来看一下，这就是我们可耐克人体系的两个儿子利斯特和赛特，得到他们对应的 steam 流的方式就是使用这个默认方法 steam 来 生成牛的。好了，接下来我们来说一下迈普体系的集合，他不能直接生成牛，但是他可以间接生成， 什么意思呢？来看一下 mate 死去，来切换一下输入法啊死去， 然后后面跟一个引推这，然后写个 mate， 你有一个哈西 mate， 这里写上死去， 后面是引踢者，那么拿到他之后，我们可以这样来做卖点，认真看踢赛特 得到箭的集合，箭的集合是一个色彩集合，那么色彩集合就可以调用这个死去母方法了。看完出艾奥特威生成左边的内容，那么这一次我们得到的就是他 剑的这个死却母瘤好了，他是间接的得到瘤的啊。来再来看 mat 点 w， 这是得到他值得集合，你看这个 wc， 他返回的是个可来开始集合，那么这个可来开始集合，他就可以调用这个死去的方法来生成牛。 ctrl altv 生成左边的内容，那么这里就是我们的歪六所对应的死去母牛。 那么再接着来一个迈普点 nt 四艾特来看一下，他得到的也是一个四艾特集合，那么这个一样可以调用 steam 方法。 ctrl altv 生成左边的内容，那么这里是我们的这个箭之这对象所对应的理由。 好嘞，那么这是迈普及和间接的生成流，这是箭所对应的流，这是直所对应的流，这是间直段对向对应的流。好了，接着我们来说第三 个数组，他可以通过死去母接口的静态方法来生成流。那么在这里首先我们来定一个数组，死去中国号 s t r。 那么这里我们给一些数据。 哈喽， word 加了。好嘞，有了这个之后进来看一下啊，我们用死去他的 静态奥方法，他是可变参数的，所以我们可以直接传一个数组过来， ctrl altv 生成左边的内容，这样我们就得到了 个这个数组，这串数组对应的流，我们该起个名叫 s t r 哦，瑞斯群。好的，那么这里他既然可以 传一个数组，而且他是可变参数的，那我直接传可变参数是不是也可以呢？来看一下，那就是死吹点 out， 那么这里我们直接传这个， hello， word 加吧， ctrl altv 生成左边的内容，这样我们一样得到了一个这个字符串数足所对应的这个理由。 那么在这里我们还可以通过这个什么点啊，来给一个樱桃类型的数据，十二十 三十 ctrl altv。 认真看，那么这是我们因特数据所对应的 ctrl m 零。好嘞，那么在这里泛行他写的是引帖点啊，这个你得知道。好嘞，这样我们就通过这几种方式来 生成了我们的牛。注意，迈普集合他不能直接生成牛，但是他可以间接的生成他的腱直 以及建制对等一等流。我们的可拉伸体系的集合和我们的数组，他都是有方法能够直接生成流的。好了，到这关于四川美流的常见的三种生成方式我们就讲完了。

前两周呢，花了很多时间调研和测试了 spring park 跟 d k 这两款当下比较受大家关注的流失计算管理平台， 这里啊，就给大家针对这两款软件做一个简单的总结。首先，这两款软件存在的目的是为了解决一个流失计算任务必须要经历代码开发并 任务提交、状态监控、异常告景等一系列冷藏的流程而带来的低效和管理问题的设计的初衷呢，是为了让流失计算任务的开发者只用专注于业务计算逻辑的开发，不用过多考虑编码完成之后啊，随之而来的运为管理问题 实现所谓的一站式，这个初衷当然是好的，但是呢，从这两周的测试体验来看，这两款软件能下载到的最新版本都存在很多的缺陷跟不足，对于 一个新手而言啊，总体来说是比较难用的。首先啊，第一个最明显的缺陷就是这两款软件的官方文档对于如何部署跟使用，这部分的文字描述比较粗糙，很多必要性细节是缺失的，而且一些章节的结构设置也不太合理，甚至个别地方有错误， 这样就会导致第一次使用这款软件来的，要么需要花大量的时间去文档的各个边角找到有价值的信息给拼凑起来，要么呢，就需要自己有比较丰富的软件运维经验和比较好的 linux 基础， 否则啊，想顺利的部署成功没有那么容易。第二个就是可能这两款软件目前还只是在孵化和初步研发阶段的人，所以很多官网宣传的功能啊，要么暂时没有实现，要么呢，使用起来很别扭， bug 很多，所以想真正从零到一把他们给用起来啊，你 可能要经历一番折磨。当然，在使用这两款软件的过程中啊，还涉及到了很多其他具体的细节，有兴趣的同学呢，可以去看我的这几篇公众号文章，比较详细的阐述了我在这个过程中踩过的坑。另外呢，还想表达一个观点，那就是对于这种新推出的技术， 不要轻易被他表面的营销和推广所影响，因为对于他们而言，就是希望你多使用，多踩坑，从而给他们提供更多的改进和优化方案。但是对于使用者而言，我们使用工具的目的绝大多数时候是为了提升工作效率的。而如果这个宣称能够简化你开发流程的软件， 在你使用的时候反而带来了更多的麻烦，那就有点得不偿失了。而且啊，从这两款软件提供的功能来看呢，他们对于开发者而言，起到的是一个锦上添花的效果，并不是雪中送炭的 刚需。所以我的个人观点是，如果一款开源文件还只是起步萌芽阶段的话，你可以因为好奇去尝尝鲜，但是如果你想要把它用于生产环境，那你还是最好要三思，因为一旦出现一些不可预知的 bug， 坑的可能是你自己。最后啊，像这种能简化开发流程，实现低代码特性，只让程序员专注于业务逻辑软件的工具，虽然能够加速你的工作效率， 但是你必须同时清醒的认识到一点，那就是工具本身如果越智能的话，那么你的个人价值就会越单一，你的核心竞争力就会在这种智能化中逐渐的上市。

扎弯一分钟创建 stream 并行流创建 stream 并行流有两种方式，第一种方式是在当前有一个 list 集合的基础上， 使用集合接口的 parallel stream 方法创建并行流， 然后对 parallel stream 做出判断。 根据打印结果可以看到 parallel stream 是病行流。假如我们现在有一个 stream 串行流， 这时可以使用 basic 接口中的 parallel 方法将串行流转化为病行流， 然后打印判断结果， 可以看到判断结果为处。以上就是创建 stream 并行流的两种方法，你学会了吗？记得关注再走哦！