third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: optimize RejectedExecutionHandlerFactory

Browse Source
This commit is contained in:
tjq 2022-09-12 09:36:29 +08:00
parent 614349370a
commit 3869b115ce
2 changed files with 5 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
powerjob-server/powerjob-server-common/src/main/java/tech/powerjob/server/common/RejectedExecutionHandlerFactory.java
View File

@ -21,10 +21,9 @@ public class RejectedExecutionHandlerFactory {
* @param source log name * @param source log name
* @return A handler for tasks that cannot be executed by ThreadPool * @return A handler for tasks that cannot be executed by ThreadPool
*/ */
public static RejectedExecutionHandler newReject(String source) { public static RejectedExecutionHandler newDiscard(String source) {
return (r, p) -> { return (r, p) -> {
log.error("[{}] ThreadPool[{}] overload, the task[{}] will be dropped!", source, p, r); log.error("[{}] ThreadPool[{}] overload, the task[{}] will be Discard, Maybe you need to adjust the ThreadPool config!", source, p, r);
log.warn("[{}] Maybe you need to adjust the ThreadPool config!", source);
}; };
} }
@ -35,8 +34,7 @@ public class RejectedExecutionHandlerFactory {
*/ */
public static RejectedExecutionHandler newCallerRun(String source) { public static RejectedExecutionHandler newCallerRun(String source) {
return (r, p) -> { return (r, p) -> {
log.warn("[{}] ThreadPool[{}] overload, the task[{}] will run by caller thread!", source, p, r); log.error("[{}] ThreadPool[{}] overload, the task[{}] will run by caller thread, Maybe you need to adjust the ThreadPool config!", source, p, r);
log.warn("[{}] Maybe you need to adjust the ThreadPool config!", source);
if (!p.isShutdown()) { if (!p.isShutdown()) {
r.run(); r.run();
} }
@ -50,8 +48,7 @@ public class RejectedExecutionHandlerFactory {
*/ */
public static RejectedExecutionHandler newThreadRun(String source) { public static RejectedExecutionHandler newThreadRun(String source) {
return (r, p) -> { return (r, p) -> {
log.warn("[{}] ThreadPool[{}] overload, the task[{}] will run by a new thread!", source, p, r); log.error("[{}] ThreadPool[{}] overload, the task[{}] will run by a new thread!, Maybe you need to adjust the ThreadPool config!", source, p, r);
log.warn("[{}] Maybe you need to adjust the ThreadPool config!", source);
if (!p.isShutdown()) { if (!p.isShutdown()) {
String threadName = source + "-T-" + COUNTER.getAndIncrement(); String threadName = source + "-T-" + COUNTER.getAndIncrement();
log.info("[{}] create new thread[{}] to run job", source, threadName); log.info("[{}] create new thread[{}] to run job", source, threadName);

2
powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/config/ThreadPoolConfig.java
View File

@ -46,7 +46,7 @@ public class ThreadPoolConfig {
executor.setQueueCapacity(8192); executor.setQueueCapacity(8192);
executor.setKeepAliveSeconds(60); executor.setKeepAliveSeconds(60);
executor.setThreadNamePrefix("omsBackgroundPool-"); executor.setThreadNamePrefix("omsBackgroundPool-");
executor.setRejectedExecutionHandler(RejectedExecutionHandlerFactory.newReject("PowerJobBackgroundPool")); executor.setRejectedExecutionHandler(RejectedExecutionHandlerFactory.newDiscard("PowerJobBackgroundPool"));
return executor; return executor;
} }