Merge branch 'V1.4'

# Conflicts:
#	src/main/java/com/jd/platform/async/executor/Async.java
#	src/main/java/com/jd/platform/async/wrapper/WorkerWrapper.java
This commit is contained in:
wuweifeng10
2021-01-25 13:48:57 +08:00
parent 442aa49dd7
commit efaba4a113

View File

@@ -20,7 +20,9 @@ public class Async {
15L, TimeUnit.SECONDS,
new LinkedBlockingQueue<>(),
(ThreadFactory) Thread::new);
/**
* 注意这里是个static也就是只能有一个线程池。用户自定义线程池时也只能定义一个
*/
private static ExecutorService executorService;
/**
@@ -130,6 +132,13 @@ public class Async {
* 关闭线程池
*/
public static void shutDown() {
shutDown(executorService);
}
/**
* 关闭线程池
*/
public static void shutDown(ExecutorService executorService) {
if (executorService != null) {
executorService.shutdown();
} else {