小编lam*_*lus的帖子

仅在ExecutorService中使用线程的子集

在典型的JAVA应用程序中,可以配置一个全局ExecutorService来管理全局线程池。可以说我配置了100个线程的固定线程池:

ExecutorService threadPool = Executors.newFixedThreadPool(100);
Run Code Online (Sandbox Code Playgroud)

现在假设我有一个要上传到服务器的1000个文件的列表,对于每次上传,我都会创建一个可调用的文件,以处理该文件的上传。

List<Callable> uploadTasks = new ArrayList<Callable>();
// Fill the list with 1000 upload tasks
Run Code Online (Sandbox Code Playgroud)

我如何将最大同时上传数量限制为5个?

如果我做

threadPool.invokeAll(uploadTasks);
Run Code Online (Sandbox Code Playgroud)

我无法控制我的1000个任务要执行多少个线程。可能并行运行100个上载,但我只希望最多5个。我想创建某种子执行器,它使用父执行器线程的子集。我不想仅为上传而创建一个新的单独的executorService,因为我想全局管理我的线程池。

你们中的任何人都知道该怎么做或是否存在现有的实现吗?理想情况是

ExecutorService uploadThreadPool = Executors.createSubExecutor(threadPool,5);
Run Code Online (Sandbox Code Playgroud)

非常感谢,

安托万

java multithreading executorservice

6
推荐指数
1
解决办法
410
查看次数

标签 统计

executorservice ×1

java ×1

multithreading ×1