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

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();
    }

}

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

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!