-
public class TaskControllerTaskController: hasCallback:确保回调只触发一次,使用 AtomicBoolean 保证线程安全。 CountDownLatch:用于等待所有任务完成,确保在所有任务失败时触发失败回调。 executeTasks 方法: 提交任务到线程池,同时控制并发数。 如果某个任务成功,触发成功回调并停止后续任务的提交。 如果所有任务失败,触发失败回调。 TaskCallback 接口: 定义了 onSuccess 和 onFailure 方法,用于回调通知任务执行结果。 RunnableTask: 表示一个任务,包含任务 ID 和运行逻辑。 run 方法模拟任务执行,并返回成功或失败。
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public interfaceTaskController.TaskCallbackpublic classTaskController.RunnableTask
-
Constructor Summary
Constructors Constructor Description TaskController(int maxConcurrent)
-
Method Summary
Modifier and Type Method Description voidexecuteTasks(List<TaskController.RunnableTask> tasks, TaskController.TaskCallback callback)-
-
Method Detail
-
executeTasks
void executeTasks(List<TaskController.RunnableTask> tasks, TaskController.TaskCallback callback)
-
-
-
-