// 獲取到要插入數(shù)據(jù)庫的集合，數(shù)據(jù)量很大
List<User> list = new ArrayList<>();
// 插入數(shù)據(jù)到MySQL中
userService.saveBatch(list);

@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {
	@Autowired
	private UserMapper userMapper;
	@Override
	public void insert() {
    	// 通過一系列操作獲取到要插入的集合，在此使用list代替
    	List<User> list = new ArrayList<>();
    	// 每次插入的數(shù)量
    	int batchSize = 1000;
    	// 計算需要分多少批插入數(shù)據(jù)庫
    	int batch = list.size() / batchSize;
    	// 計算最后一批的大小
    	int lastSize = list.size() % batchSize;
    	// 將篩選出的結(jié)果分批次添加到表中
    	for (int i = batchSize; i <= batch * batchSize; i = i + batchSize) {
        	// 截取本次要添加的數(shù)據(jù)
        	List<User> insertList = list.subList(i - batchSize, i);
        	// 添加本批次數(shù)據(jù)到數(shù)據(jù)庫中
        	userMapper.batchInsert(insertList);
    	}
    	// 最后一批元素的大小是否為0
    	if (lastSize != 0) {
        	// 如果元素有剩余則將所有元素作為一個子列表一次性插入
        	List<User> lastList = list.subList(batchSize * batch, list.size());
        	// 添加集合到數(shù)據(jù)庫中
        	userMapper.batchInsert(lastList);
    	}
	}
}

/**
 * 用戶數(shù)據(jù)持久化接口
 *
 * @author Dream_飛翔
 * @since 2023/5/16
 */
public interface UserMapper extends BaseMapper<User> {
	/**
     * 添加指定集合內(nèi)的數(shù)據(jù)到數(shù)據(jù)庫中
     *
     * @param insertList 要添加的內(nèi)容
     * @return 受影響的行數(shù)
     */
    Integer batchInsert(@Param("insertList") List<User> insertList);
}

<?xml version="1.0" encoding="utf-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.zrkizzy.data.mapper.UserMapper">
	<!-- 批量添加數(shù)據(jù)到數(shù)據(jù)庫中 -->
	<insert id="batchInsert">
        INSERT INTO tb_user (id, username, password)
        VALUES
        <foreach collection ="userList" item="user" separator =",">
            (#{user.id}, #{user.username}, #{user.password})
        </foreach>
    </insert>
</mapper>

@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {
	@Autowired
	private UserMapper userMapper;
	@Override
	public void insert() {
    	// 通過一系列操作獲取到要插入的集合，在此使用list代替
    	List<User> list = new ArrayList<>();
        // 獲取虛擬機(jī)可用的最大處理器數(shù)量
        int availableProcessors = Runtime.getRuntime().availableProcessors();
        // 獲取要添加的數(shù)據(jù)集合大小
        int total = list.size();
        // 每次插入的數(shù)量
        int batchSize = 1000;
        // 計算需要分多少批插入數(shù)據(jù)庫（向上取整）
        int totalBatch = (total + batchSize - 1) / batchSize;
        // 手動創(chuàng)建線程池
        ExecutorService executor = new ThreadPoolExecutor(
                // 線程池核心線程數(shù)量
                availableProcessors,
                // 線程池最大數(shù)量
                availableProcessors + 1000,
                // 空閑線程存活時間
                1000,
                // 時間單位
                TimeUnit.MILLISECONDS,
                // 線程池所使用的緩沖隊列
                new ArrayBlockingQueue<>(100),
                // 線程池對拒絕任務(wù)的處理策略
                new ThreadPoolExecutor.CallerRunsPolicy());
        // 將篩選出的結(jié)果分批次添加到表中
        for (int batchIndex = 0; batchIndex < totalBatch; batchIndex++) {
            // 當(dāng)前插入批次的起始索引
            int startIndex = batchIndex * batchSize;
            // 當(dāng)前插入批次的結(jié)束索引
            int endIndex = Math.min((batchIndex + 1) * batchSize, total);
            // 截取本次要添加的數(shù)據(jù)
            List<LuckyDrawHistory> insertList = list.subList(startIndex, endIndex);
            // 將每個批次的插入邏輯封裝成一個Runnable對象
            Runnable task = () -> {
                // 添加本批次數(shù)據(jù)到數(shù)據(jù)庫中
                userMapper.batchInsert(insertList);
            };
            // 提交添加任務(wù)
            executor.submit(task);
        }
        // 關(guān)閉線程池釋放資源
        executor.shutdown();
    }
}