Package cn.net.pap.task.util

Class DynamicTaskExecutorUtil

java.lang.Object

cn.net.pap.task.util.DynamicTaskExecutorUtil

public class DynamicTaskExecutorUtil
extends Object

动态任务执行工具类（线程池由外部管理）

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	DynamicTaskExecutorUtil.TaskProgress
static final class	DynamicTaskExecutorUtil.TaskResult<T>

Constructor Summary

Constructors

Constructor	Description
DynamicTaskExecutorUtil()

Method Summary

Modifier and Type	Method	Description
static <T> List<DynamicTaskExecutorUtil.TaskResult<T>>	executeCallableTasks(ExecutorService executor, Collection<? extends Callable<T>> tasks, Integer maxConcurrent, Consumer<DynamicTaskExecutorUtil.TaskProgress> progressListener)	执行可调用任务集合
static void	executeTasks(ExecutorService executor, Collection<Runnable> tasks, Integer maxConcurrent, Consumer<DynamicTaskExecutorUtil.TaskProgress> progressListener)	执行无返回值任务

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DynamicTaskExecutorUtil

public DynamicTaskExecutorUtil()

Method Details

executeCallableTasks

public static <T>
List<DynamicTaskExecutorUtil.TaskResult<T>> executeCallableTasks(ExecutorService executor,
 Collection<? extends Callable<T>> tasks,
 Integer maxConcurrent,
 Consumer<DynamicTaskExecutorUtil.TaskProgress> progressListener)

执行可调用任务集合

Type Parameters:

T - 返回类型

Parameters:

executor - 线程池（必须由调用方初始化和销毁）

tasks - 任务集合

maxConcurrent - 最大并发数（null表示不限制）

progressListener - 进度监听器（可选）

Returns:

任务结果列表（按提交顺序）

executeTasks

public static void executeTasks(ExecutorService executor,
 Collection<Runnable> tasks,
 Integer maxConcurrent,
 Consumer<DynamicTaskExecutorUtil.TaskProgress> progressListener)

执行无返回值任务