
我用 MongoDB 的 upsert 和$inc 实现了一个简单的自增计数器,但是却发现当对一个键并发自增计数时,会丢失数据,让人百思不得其解啊
我的 MongoDB 进程是在本机运行的,计数器主要代码如下: 计数器的 incr 实现:
public boolean incr(String key) {
checkKey(key); UpdateResult result = mongoTemplate.upsert(query(Criteria.where("key").is(key)), new Update().inc("value", 1), MongoCounter.class, COLLECTION_NAME); return result.wasAcknowledged(); } 测试代码:
int count = 200; ExecutorService executor = Executors.newCachedThreadPool(); String key = "incrkey"; for (int i = 0; i < count; i++) { executor.submit(() -> counter.incr(key)); } assertTrue(counter.getCounter(key) == count); executor.shutdown(); counter.delCounter(key); 在测试时,开了一个线程池,用多个线程同时向一个初始没有值的键连续调用 n 次 incr,但是结果发现总是会丢失几次更新,难道原子性更新的前提是并发量不能太大吗?
请懂 MongoDB 的人指点一二啊
1 xmh51 2019 年 4 月 22 日 不应该立马 executor.shutdown(); 你等等 java 执行完异步线程再关闭......... |
2 DovaKeen OP @xmh51 executor.shutdown();执行之后,已经提交过的任务还是会跑完才关闭的,不会直接关闭线程池呀,而且我注释掉了这一句后,还是会丢失更新,, |