添加异步任务工具类
This commit is contained in:
@@ -16,19 +16,19 @@ public class AsyncLatchUtils {
|
|||||||
* @param executor 指定执行此任务的线程池
|
* @param executor 指定执行此任务的线程池
|
||||||
* @param runnable 需要异步执行的具体业务逻辑
|
* @param runnable 需要异步执行的具体业务逻辑
|
||||||
*/
|
*/
|
||||||
public static void submitTask(Executor executor, Runnable runnable) {
|
public static void submitTask(Executor executor, Runnable runnable) {
|
||||||
THREADLOCAL.get().add(new TaskInfo(executor, runnable));
|
THREADLOCAL.get().add(new TaskInfo(executor, runnable));
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 获取当前线程已提交的任务列表,并自动清理当前线程的已提交任务列表。
|
* 获取当前线程已提交的任务列表,并自动清理当前线程的已提交任务列表。
|
||||||
* @return
|
* @return
|
||||||
*/
|
*/
|
||||||
private static List<TaskInfo> popTask() {
|
private static List<TaskInfo> popTask() {
|
||||||
List<TaskInfo> taskInfos = THREADLOCAL.get();
|
List<TaskInfo> taskInfos = THREADLOCAL.get();
|
||||||
THREADLOCAL.remove();
|
THREADLOCAL.remove();
|
||||||
return taskInfos;
|
return taskInfos;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 触发所有已提交任务的执行,并同步等待它们全部完成。
|
* 触发所有已提交任务的执行,并同步等待它们全部完成。
|
||||||
|
|||||||
Reference in New Issue
Block a user