如何等一个事务结束后,在执行线程的内容。 - V2EX
V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
Renco
V2EX    Java

如何等一个事务结束后,在执行线程的内容。

  •  
  •   Renco 2019-08-29 11:51:12 +08:00 4332 次点击
    这是一个创建于 2240 天前的主题,其中的信息可能已经有所发展或是发生改变。

    有一个场景

    在执行完一系列的数据库操作后,通过获取数据库的流水,来发送校验短信。但是这个数据是在之前一系列的数据库操作的,数据库操作有事务,必须得等方法执行完成后才可以提交。

    我这边发送校验短信写在了事务操作里通过线程池开了一个线程来执行的,然后会有这样的情况,有些时候会发送校验短信线程先获取 cpu 执行,然后导致获取不到数据库的流水数据,线程创建运行后,如何可以等待事务的执行结束后再执行线程内的操作。

    我目前的写法是,在线程里加了 Thread.sleep(1000),让线程进行睡眠,在 1000ms 内 事务的操作般都已经执行结束,此时执行线程内的发送校验短信操作。

    但我不知道我这个方法会不会有什么影响,有学过线程操作,但是第一次在实际开发环境中使用到,问问有什么更好的处理方法。

    14 条回复    2019-08-29 16:59:54 +08:00
    bitholic
        1
    bitholic  
       2019-08-29 12:42:35 +08:00 via iPhone
    如果用的是 spring,可以看下
    bitholic
        2
    bitholic  
       2019-08-29 12:42:49 +08:00 via iPhone
    TransactionSynchronizationManager
    geelaw
        3
    geelaw  
       2019-08-29 12:46:01 +08:00 via iPhone
    为什么不在事务结束后再启动另一个线程?

    用(反复)延时的方法进行同步是最后大招,不到万不得已不能使用。
    Fren
        4
    Fren  
       2019-08-29 12:59:39 +08:00
    这类操作不是应该丢到 MQ,解耦的么。。
    woscaizi
        5
    woscaizi  
       2019-08-29 13:05:47 +08:00 via iPhone   1
    应该改成同步操作吧。
    话说获取流水为何要开启事务?还有写的操作?
    Lin0936
        6
    Lin0936  
       2019-08-29 13:10:59 +08:00
    正好之前有差不多的需求,于是抽了个共通,在需要等待的地方调 await()就完事。( JAVA 新人,写得不对的请大佬指摘)


    public class Task {

    private boolean completed = false;

    synchronized public void await() {
    while (!completed) {
    try {
    this.wait();
    } catch (InterruptedException e) {
    e.printStackTrace();
    }
    }
    }

    synchronized private void complete() {
    completed = true;
    this.notifyAll();
    }

    public void async(Runnable runnable) {
    new Thread(() -> {
    runnable.run();
    complete();
    }).start();
    }
    }
    jiejiecool
        7
    jiejiecool  
       2019-08-29 13:59:18 +08:00   1
    TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
    @Override
    public void afterCommit() {

    }
    });
    sonice
        8
    sonice  
       2019-08-29 14:03:13 +08:00   1
    @Lin0936 synchronized 写在最前面看着好别扭。。。
    Renco
        9
    Renco  
    OP
       2019-08-29 14:16:06 +08:00
    @Fren 目前公司框架没有 MQ
    Renco
        10
    Renco  
    OP
       2019-08-29 14:16:38 +08:00
    @woscaizi 确实有事务操作应该同步,写代码写错了
    GreatEscape
        11
    GreatEscape  
       2019-08-29 14:31:49 +08:00
    @TransactionEventListener 注解,添加事务监听处理。
    Renco
        12
    Renco  
    OP
       2019-08-29 14:33:28 +08:00
    @jiejiecool 感谢!此操作可行
    Raymon111111
        13
    Raymon111111  
       2019-08-29 14:34:42 +08:00
    这种正确的做法确实是 MQ 解耦
    larry123
        14
    larry123  
       2019-08-29 16:59:54 +08:00
    CountDownLatch 了解一下
    关于     帮助文档     自助推广系统     博客     API     FAQ     Solana     6178 人在线   最高记录 6679       Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 24ms UTC 01:57 PVG 09:57 LAX 18:57 JFK 21:57
    Do have faith in what you're doing.
    ubao msn snddm index pchome yahoo rakuten mypaper meadowduck bidyahoo youbao zxmzxm asda bnvcg cvbfg dfscv mmhjk xxddc yybgb zznbn ccubao uaitu acv GXCV ET GDG YH FG BCVB FJFH CBRE CBC GDG ET54 WRWR RWER WREW WRWER RWER SDG EW SF DSFSF fbbs ubao fhd dfg ewr dg df ewwr ewwr et ruyut utut dfg fgd gdfgt etg dfgt dfgd ert4 gd fgg wr 235 wer3 we vsdf sdf gdf ert xcv sdf rwer hfd dfg cvb rwf afb dfh jgh bmn lgh rty gfds cxv xcv xcs vdas fdf fgd cv sdf tert sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf shasha9178 shasha9178 shasha9178 shasha9178 shasha9178 liflif2 liflif2 liflif2 liflif2 liflif2 liblib3 liblib3 liblib3 liblib3 liblib3 zhazha444 zhazha444 zhazha444 zhazha444 zhazha444 dende5 dende denden denden2 denden21 fenfen9 fenf619 fen619 fenfe9 fe619 sdf sdf sdf sdf sdf zhazh90 zhazh0 zhaa50 zha90 zh590 zho zhoz zhozh zhozho zhozho2 lislis lls95 lili95 lils5 liss9 sdf0ty987 sdft876 sdft9876 sdf09876 sd0t9876 sdf0ty98 sdf0976 sdf0ty986 sdf0ty96 sdf0t76 sdf0876 df0ty98 sf0t876 sd0ty76 sdy76 sdf76 sdf0t76 sdf0ty9 sdf0ty98 sdf0ty987 sdf0ty98 sdf6676 sdf876 sd876 sd876 sdf6 sdf6 sdf9876 sdf0t sdf06 sdf0ty9776 sdf0ty9776 sdf0ty76 sdf8876 sdf0t sd6 sdf06 s688876 sd688 sdf86