java多线程同时更新和查询数据库并发

Question

java多线程

使用CompletionService提交异步任务，直接上代码

final int count = 1000;

public static final  ExecutorService executorService = Executors.newFixedThreadPool(3);

public void deal(){
        CompletionService cs = new ExecutorCompletionService(executorService);
for(i=0;i<100;i++){
List<Object> datalist = dao.selectList("select * tableName where state = 0");
cs.submit(datalist)
}
 CountDownLatch latch = new CountDownLatch(100);
for(i=0;i<100;i++){
  executorService.submit(()->{
        dao.updateState(update tableName set state = 1 limit i,1);
        latch.countDown();
     });

}
 latch.await();
        if(count - 100 > 0){
        //此处调用的全是和第一次的一模一样
                deal();
    }

}

内层调用获取到的数据全部一模一样，尝试过加读写锁，都不生效,求助

Answer 1

不知道你这个问题是否已经解决, 如果还没有解决的话:

• 你可以参考下这篇文章：java多线程共享数据、线程同步与互斥

如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 写成博客, 将相关链接放在评论区, 以帮助更多的人 ^-^