private SqlSessionTemplate sqlSessionTemplate;
public void threadInsert(List studentVOList) throws SQLException {
long start = System.currentTimeMillis();
Connection connection = sqlSessionTemplate.getConnection();
CacheTestMapper cacheTestMapper
= sqlSessionTemplate
.getSqlSessionFactory()
.openSession()
.getMapper(CacheTestMapper.class);
try {
//设置手动提交
connection.setAutoCommit(false);
//先删除数据
cacheTestMapper.deleteStudentById(1L);
//获取线程池
ExecutorService executorService = ExecutorUtil.getThreadPool();
//拆分数据创建任务
List> lists = this.averageAssign(studentVOList, 5);
Thread[] threads = new Thread[lists.size()];
//监控子线程执行完毕,再执行主线程,要不然会导致主线程关闭,子线程也会随着关闭
CountDownLatch countDownLatch = new CountDownLatch(lists.size());
for (int i = 0; i list = lists.get(i);
threads[i] = new Thread(() -> {
try {
//批量添加,mybatisPlus 中自带的 batch 方法
cacheTestMapper.batchInsert(list);
} finally {
countDownLatch.countDown();
}
});
}
for (int i = 0; i
