分组组织线程，并为每个组设置不同的最大线程
|
我正在使用Spring ThreadPoolTaskExecutor来执行我的线程。
我想将我的线程分为几组，并且每个组将具有不同的最大允许线程数。
例如，如下所示：
for (MyTask myTask : myTaskList){
threadPoolTaskExecutor.setMaxThreadsForGroup(myTask.getGroupName(), myTask.getMaxThreads());
threadPoolTaskExecutor.execute(myTask, myTask.getGroupName());
}
没有找到相关结果
已邀请:
1 个回复
屡倒雷图
ExecutorService executor = ... int groupThreadLimit = 3; final BlockingQueue<Runnable> groupTaskQueue = ...; // Add all your tasks to the groupTaskQueue. for(int i = 0; i < groupThreadLimit; i++) { executor.execute(new Runnable() { public void run() { while(true) { Runnable r = groupTaskQueue.pollFirst(); if(r == null) { return; // All tasks complete or being processed. Queue empty. } r.run(); } } }); }