V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
fadedos
V2EX  ›  Java

各位彦祖, Java 多线程问题请教

  •  
  •   fadedos · 2021-07-29 20:18:26 +08:00 · 1405 次点击
    这是一个创建于 973 天前的主题,其中的信息可能已经有所发展或是发生改变。

    java 多线程问题请教

    问题描述:

    1. http 请求到后台,一个 list 数据到后台,返回结果的实时性要求比较高
    2. list 中多条明细,需要根据一定的规则进行筛选 ,比较耗时很久,此处想采用多线程优化
    3. 关键点: 在筛选过程中, 子线程的筛选规则需要查询 表 C 和表 D; 获得值
    4. 筛选 ok,得到值,会添加到明细中,然后分别会落四张表,表 A,表 B,表 C,表 D
    5. 关键点 2: 只要一条明细插入失败,所有的记录进行回滚
    xuanbg
        1
    xuanbg  
       2021-07-29 20:56:47 +08:00
    貌似没有返回什么结果啊???这样开个新的线程慢慢写或者丢进消息队列异步处理就好了,都是立马就能返回成功的。
    fadedos
        2
    fadedos  
    OP
       2021-07-29 21:04:06 +08:00
    @xuanbg 返回结果: 各条明细筛选出来的值, 会放在 list 中,再次给前台
    放到消息队列中, 错了一个怎么回滚呢?
    clickhouse
        3
    clickhouse  
       2021-07-29 21:42:26 +08:00
    看 2 说的,你想多线程优化的只是筛选,那么多线程筛选即可,反正只查表。“一条明细插入失败,所有的记录进行回滚”不就是正常的事务嘛。
    fadedos
        4
    fadedos  
    OP
       2021-07-29 21:52:25 +08:00
    @clickhouse
    目前情况:
    1.子线程查询筛选,在查表 C,表 D 时候,会发生锁表,导致子线程一直等待
    2. 落表 A,B,C,D 是在 main 线程 (接手别人的代码)

    改良思路:
    1. 将落表逻辑提到子线程中,各个明细只管自己

    想到的问题:
    1. 一个线程失败,其他线程有插入成功, 这个整体回滚怎么做?
    DreamSpace
        5
    DreamSpace  
       2021-07-29 23:14:50 +08:00 via Android
    list.parallelStream() 最后 reduce 成一个 Map<String,List<?>>,遍历 Map 批量插入
    fadedos
        6
    fadedos  
    OP
       2021-07-30 00:05:43 +08:00
    @DreamSpace 能详细说说嘛? 这个流,直接在 main 线程使用? 写 java 写的少
    BQsummer
        7
    BQsummer  
       2021-07-30 10:08:29 +08:00
    @fadedos 多线程事务用注解实现不了吧,得手写吧,难度立马大了很多
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   我们的愿景   ·   实用小工具   ·   1150 人在线   最高记录 6543   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 24ms · UTC 18:32 · PVG 02:32 · LAX 11:32 · JFK 14:32
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.