git00ll 最近的时间轴更新
git00ll

git00ll

V2EX 第 447415 号会员,加入于 2019-10-17 12:19:31 +08:00
Project Reactor,如何实现主线程消费报错时停止 Flux 流
Java  •  git00ll  •  20 天前  •  最后回复来自 git00ll
5
git00ll 最近回复了
6 天前
回复了 111qqz 创建的主题 问与答 给女票选生日礼物,有什么建议?
无论买啥,建议再搭配一把鲜花
@chaosrb79 酷安,qq 浏览器评论区 找找看
for update 。简单 暴力。性能也不差
20 天前
回复了 lianglu 创建的主题 程序员 Java 有什么开源框架值得深入研究?
jackson 也值得看
20 天前
回复了 lianglu 创建的主题 程序员 Java 有什么开源框架值得深入研究?
netty
project.reactor
openFeign
spring gateway
vertx
@yazinnnn
业务场景里有一些限制,
1. 需要保持输入和输出的顺序一致,
2. 流中的数据从文件中读取的,数据量非常大,无法全部加载到内存。只能边读取边处理。
3.处理过程中其中一条处理错误时,算失败,中断流不再继续。

一方面 stream 的并行流没有拉模式,无法精准控制载入内存的数据行数。
且并行 stream 提供的 api 太少,相比于 reactor 提供的控制选项不足
@yazinnnn 假设 toInt 这个操作是比较耗时的,可以实现将 toInt 放置在多核上运行,最终结果再汇聚到主线程上。
因为主线程上开启了传统注解事务,需要在主线程上操作 Flux 的处理结果
30 分钟是指现实世界中的每 30 分钟作为一个区间吗?
感觉建张表存就可以了,内存里持有当前区间最大值,处理数据时比内存中值大就更新到数据库,否则就跳过。

如果是滚动 30 分钟,可以使用找个时序数据库用一下。
23 天前
回复了 awanganddong 创建的主题 MySQL mysql 并发操作的问题
for update 没问题的,每秒 4000 次
@dingwen07 好的,我尝试一下关闭现代待机试试,看以后能否复现了
关于   ·   帮助文档   ·   API   ·   FAQ   ·   我们的愿景   ·   广告投放   ·   感谢   ·   实用小工具   ·   3446 人在线   最高记录 5497   ·     Select Language
创意工作者们的社区
World is powered by solitude
VERSION: 3.9.8.5 · 21ms · UTC 04:13 · PVG 12:13 · LAX 20:13 · JFK 23:13
♥ Do have faith in what you're doing.