首页 > 编程语言 >JUC并发编程学习笔记(十二)Stream流式计算

JUC并发编程学习笔记(十二)Stream流式计算

时间:2023-11-05 20:34:16浏览次数:35  
标签:JUC return Stream 流式 User 计算 new

Stream流式计算

什么是Stream流式计算

大数据:存储+计算

集合、MySql这些的本质都是存储东西的;

计算都应该交给流来操作!

一个案例说明:函数式接口、lambda表达式、链式编程、Stream流式计算

package org.example.stream;

import java.util.Arrays;

import java.util.List;
import java.util.function.Predicate;

/*
 *   题目要求:一分钟内完成此题   只能用一行代码
 *   现在有五个用户!筛选:
 *   1、id必须是偶数
 *   2、年龄名必须大于23岁
 *   3、用户名转换为大写字母
 *   4、用户名字母倒着排序
 *   5、只输出一个用户!!
 * */
public class Test {

    public static void main(String[] args) {
        User u1 = new User(1, "a", 21);
        User u2 = new User(2, "b", 22);
        User u3 = new User(3, "c", 23);
        User u4 = new User(4, "d", 24);
        User u5 = new User(5, "e", 25);
        User u6 = new User(6, "f", 26);
//        集合就是存储
        List<User> users = Arrays.asList(u1, u2, u3, u4, u5, u6);
//        计算交给Stream
        /*
        *新时代程序员:lambda表达式、链式编程、函数式接口、Stream流式计算
        * */
        users.stream().filter(u -> {
                    return (u.getId() % 2 == 0);
                }).filter(u -> {
                    return (u.getAge() > 23);
                })
                .map(u -> {
                    return u.getName().toUpperCase();//转换大写
                }).sorted((uu1, uu2) -> {
                    return uu2.compareTo(uu1);//比较转换
                }).limit(1).forEach(System.out::println);

    }
}

标签:JUC,return,Stream,流式,User,计算,new
From: https://www.cnblogs.com/nhgtx/p/17806020.html

相关文章

  • JUC并发编程学习(十一)四大函数式接口(必备)
    四大函数式接口(必备)程序员:泛型、反射、注解、枚举新时代程序员:lambda表达式、链式编程、函数式接口、Stream流式计算函数式接口:只有一个方法的接口@FunctionalInterfacepublicinterfaceRunnable{publicabstractvoidrun();}//@FunctionalInterface函数式接口,超......
  • JUC并发编程学习笔记(十)线程池(重点)
    线程池(重点)线程池:三大方法、七大参数、四种拒绝策略池化技术程序的运行,本质:占用系统的资源!优化资源的使用!->池化技术(线程池、连接池、对象池......);创建和销毁十分消耗资源池化技术:事先准备好一些资源,有人要用就拿,拿完用完还给我。线程池的好处:1、降低资源消耗2、提高相......
  • XStream反序列化漏洞原理分析
    一、XStream简介0x1:XStream介绍Xstream是一种OXMapping技术,是用来处理XML文件序列化的框架,在将JavaBean序列化,或将XML文件反序列化的时候,不需要其它辅助类和映射文件,使得XML序列化不再繁索。Xstream也可以将JavaBean序列化成Json或反序列化,使用非常方便。使用方便-XStream......
  • JUC并发编程学习笔记(九)阻塞队列
    阻塞队列阻塞队列队列的特性:FIFO(fistinpuptfistoutput)先进先出不得不阻塞的情况什么情况下会使用阻塞队列:多线程并发处理、线程池学会使用队列添加、移除四组API方式抛出异常不抛出异常,有返回值阻塞等待超时等待添加addofferputoffer(Ee,lo......
  • Could not find codec parameters for stream 0 (Video: h264, none)
    Couldnotfindcodecparametersforstream0(Video:h264,none)在使用视频处理工具或者播放器时,有时我们可能会遇到错误信息"Couldnotfindcodecparametersforstream0(Video:h264,none)"。这个错误提示说明在当前的环境中找不到视频流的编解码器参数,导致无法正确解......
  • JUC并发编程学习笔记(八)读写锁
    读写锁ReadWriteLockReadWriteLock只存在一个实现类那就是ReentrantReadWriteLock,他可以对锁实现更加细粒化的控制读的时候可以有多个阅读器线程同时参与,写的时候只希望写入线程是独占的Demo:packageorg.example.rw;importjava.util.HashMap;importjava.util.Map;impo......
  • Stream实战用例1
    Java8Stream代码少,功能强大,实乃效率利器。这里我列举自己常用的Stream使用示例。一.流式赋值1.从一个List转到另一个List参考objectList=objectList.stream().map(object->{ObjectobjectNew=newObject();BeanUtils.copyProperties(......
  • JUC并发编程学习笔记(七)常用的辅助类
    常用的辅助类CountDownLatch这是一个JUC计数器辅助类,计数器有加有减,这是减。使用方法packageorg.example.demo;importjava.util.concurrent.CountDownLatch;//线程计数器publicclassCountDownLatchDemo{publicstaticvoidmain(String[]args){Cou......
  • JUC并发编程学习笔记(六)Callable(简单)
    Callable(简单)callable接口和runnable接口类似,都是为了执行另外一条线程而设计的,区别是Runnable不会返回结果也不会抛出异常。1、可以有返回值2、可以抛出异常3、方法不同;run()/call();Runnable实现Runnable接口,重写run方法,无返回值//原线程classRunnableThreadimple......
  • GO语言使用redis stream队列demo
    GO语言使用redisstream队列demopackagemainimport( "context" "fmt" "github.com/go-redis/redis/v8" "time")varclient*redis.Clientvarctxcontext.Contextvarkey="my_streamKey"//keyvarmyCons......