问题描述,现A表(用户查看实验的次数)有user_id和exp_id两个字段,其中user_id加exp_id不唯一。B表有user_id,exp_id以及exp_num三个字段,其中user_id加exp_id唯一(表中未建唯一索引)。
现需要将A表的数据同步到B表,单机模式通过定时任务同步。A表的数据有10万条,为了提高同步效率,采用多线程并发同步。主线程按照游标分页查询,每页查询500条,然后将每页的数据都给独立的线程执行。为了保证user_id加exp_id唯一,只能在程序中通过加锁控制。首先按照 userId+"_"+expId
给这500条数据分组,然后循环分组,在循环中通过synchronized来加锁,锁的对象是userId+"_"+expId
,它是一个字符串,userId+"_"+expId
相同的则锁住,不同的则放过。
protected void batchMigrate(List<