ThreadPoolExecutor实现文件上传批量插入数据

一：在run()方法里写插入

package com.smartdata.pms.thread;

import com.smartdata.pms.entity.PmsProduct;
import com.smartdata.pms.mapper.PmsProductMapper;
import lombok.extern.slf4j.Slf4j;

import java.util.List;

/**
 * @ProjectName: smartdata
 * @Package: com.smartdata.pms.thread
 * @ClassName: InsertBatchRun
 * @Author: heluwei
 * @Description:
 * @Date: 2020/3/22 16:36
 * @Version: 1.0
 */
 @ Slf4j
public class InsertBatchRun implements Runnable {
    //数据层访问
    private PmsProductMapper pmsProductMapper;
    //具体插入批次
    private int batch;

    //插入的数据
    private List < PmsProduct > list;

    public InsertBatchRun(PmsProductMapper pmsProductMapper, List < PmsProduct > list, int batch) {
        this.pmsProductMapper = pmsProductMapper;
        this.list = list;
        this.batch = batch;
    }
     @ Override
    public void run() {
        try {
            for (int i