Browse Source

添加 awaitTermination

James 3 years ago
parent
commit
9f63c8c233
1 changed files with 7 additions and 0 deletions
  1. 7 0
      src/main/java/com/jfinal/kit/ScheduledKit.java

+ 7 - 0
src/main/java/com/jfinal/kit/ScheduledKit.java

@@ -151,6 +151,13 @@ public class ScheduledKit {
 			executor.shutdownNow();
 		}
 	}
+
+	/**
+	 * 在 shutdown 线程池之后,阻塞等待所有任务执行完,或发生超时,或当前线程中断,以先发生者为准
+	 */
+	public static boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
+		return executor == null || executor.awaitTermination(timeout, unit);
+	}
 }