当前位置: 首页 > article >正文

flux中的缓存

1. cache,onBackpressureBuffer。都是缓存。cache可以将hot流的数据缓存起来。onBackpressureBuffer也是缓存,但是当下游消费者的处理速度比上游生产者慢时,上游生产的数据会被暂时存储在缓冲区中,防止丢失。

2. Flux.range 默认带有无界缓冲区

Flux.interval 默认下游的consume速率不能低于produce的速率,否则直接报错。但是可以增加onBackpressureBuffer/cache让数据缓存
3. Flux.fromIterable 经过测试,应该也是属于无界缓冲区

4. zipWith自带32长度的缓存,因此可以做到适配两个flux。如果其中一个flux超过了32的缓冲,就会报错

Flux<Integer> existingFlux = Flux.interval(Duration.ofMillis(1)).map(t-> Integer.valueOf(t.intValue()));
Flux<Long> s2 = Flux.interval(Duration.ofHours(1));
existingFlux.log()
        .zipWith(s2, (httpData, existingData) ->
                existingData // 合并两个数据
        ).subscribe();
Thread.sleep(1000*10);

报错:

4. 注意默认带有无界缓冲区时,如果设置了onBackpressureBuffer(size)。则反而成为了有界缓冲区。有界会导致如果缓冲区不足以缓冲数据时,会报错


http://www.kler.cn/a/464619.html

相关文章:

  • vue2项目报错You may need an appropriate loader to handle this file type
  • 使用LINUX的dd命令制作自己的img镜像
  • Oracle 11g rac + Dataguard 环境调整 redo log 大小
  • 音视频入门基础:MPEG2-PS专题(3)——MPEG2-PS格式简介
  • Ae:合成设置 - 3D 渲染器
  • NRF24L01模块STM32通信-通信初始化
  • 《Vue3实战教程》43:Vue3TypeScript 与选项式 API
  • Java之图书管理系统
  • 单周期CPU电路设计
  • Vue.js 表单验证实战:一个简单的登录页面
  • idea最强ai辅助工具豆包的使用教程
  • 观成科技:伪猎者(APT-C-60)APT组织加密通信分析
  • 港科大开源VideoVAE+,视频重建质量全面超越最新模型
  • Rabbitmq追问
  • 基于微信小程序的面部动作检测系统
  • 几句话分析org.springframework.web.servlet.HandlerMapping体系机构
  • 在C#中,如何使用委托实现事件处理?
  • 计算机网络 (20)高速以太网
  • 【QT】:QT图形化界面概述
  • 解读一个新建的 Spring Boot 项目
  • 若依引入腾讯地图
  • FastDeploy部署paddlecls分类模型(windows)
  • element-plus大版本一样,但是小版本不一样导致页面出bug
  • 人工智能知识分享第六天-机器学习_​逻辑回归(Logistic Regression)
  • @Data
  • 关于Flutter应用国际化语言的设置