线程池操作批量上传代码

以下是一个使用Java线程池实现批量上传的示例代码：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class UploadTask implements Runnable {
    private final int startIndex;
    private final int endIndex;

    public UploadTask(int startIndex, int endIndex) {
        this.startIndex = startIndex;
        this.endIndex = endIndex;
    }

    @Override
    public void run() {
        // 执行上传操作，上传startIndex到endIndex之间的文件或数据
    }

    public static void main(String[] args) {
        int taskCount = 100; // 总的上传任务数
        int batchSize = 10; // 每个子任务上传的文件或数据数量
        int threadCount = 5; // 线程池中的线程数量

        ExecutorService executor = Executors.newFixedThreadPool(threadCount);

        for (int i = 0; i < taskCount; i += batchSize) {
            int startIndex = i;
            int endIndex = Math.min(i + batchSize, taskCount);

            Runnable task = new UploadTask(startIndex, endIndex);
            executor.execute(task);
        }

        executor.shutdown();
    }
}

在该示例代码中，通过创建一个固定大小的线程池来实现批量上传操作。在主函数中，先创建一个线程池对象，然后循环将所有的上传任务按照一定的规则拆分成多个子任务，并将每个子任务放入线程池中执行。最后等待所有任务执行完毕，关闭线程池。在UploadTask类中，实现了每个子任务的上传逻辑。