@rqxiao 这个代码也不是很明白

额 。还有补充一点#1 里 runnable 的 run 方法 最后还会有一段这样的代码，每次执行完一个线程的逻辑之后，还给他 interrupt()一下，然后自抛自捕。


```
finally {

logger.debug("{} 队列消费，标志线程为中断", Thread.currentThread().getName());
Thread.currentThread().interrupt();
throw new InterruptedException(
Thread.currentThread().getName() + ".run() interrupted : 执行完毕");
}
} catch (InterruptedException e) {
if (e.getMessage().endsWith(SysConstants.FINISH_INTERRUPTED)) {
logger.debug(e.getMessage());
} else {
logger.error(e.getMessage());
}
}
```

你是 MyISAM 引擎吗，MyISAM 引擎不支持数事物，不过还没用过 MyISAM

@hhhhhh123 一般有事物功能的话没提交确实不会更新到数据库。

@hhhhhh123 那应该就是你发的 mysql 隔离级别为 read uncommitted 读未提交 （脏读）

@hhhhhh123 只是在当前事物看到是加了 1 吧（虽然当前事物还没提交）。新开个会话，查看的话还是原来的值。

set autocommit=0;
start transaction;
update user_basic_info set pk_money=pk_money+1 where uid=123456803;
COMMIT;

这样和你加了一句 for update 是一样的把

mysql update 语句不是自带行锁吗（如果 where 的条件有索引的话）

先保持身体健康开始

@yw121141111 https://www.bilibili.com/video/BV16J411h7Rd/?from=search&seid=5852862295288315017&spm_id_from=333.337.0.0

熟练使用 juc

@memedahui 以前遇到 last packet successfully received from the server was 10,611,698 milliseconds ago ，是因为在事物里调用一个第三方耗时的 rpc 方法。写在 Controller 应该没影响吧。

事物开的时间太长了，事物中有什么耗时的方法吗

@Rache1 感谢回复，查了下 where cellphone_hash=？ and cellphone_enc=？如果这样精确查的话，可以用哈希列索引体积小的优势，更快的找到记录。虽然 cellphone_hash 有可能会重复，但是利用其索引值较短的优势提高查询效率？

查询用 hash 是什么意思。。

remove 为什么会线程不安全啊

一次锁住这 1 万条数据

238

@sujin190 不好意思。意思是 count(*) 如果是 只走索引不回表 或者 全表扫描 ，虽然都有可能是 5000w 的记录数，但因为索引 b 树结构的特点(非叶子节点只存索引数据)，和全表扫描比，走索引不回表这种情况明显的快是么。