diff --git a/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/config/ThreadPoolConfig.java b/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/config/ThreadPoolConfig.java index 5be38c3b..f16fbbda 100644 --- a/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/config/ThreadPoolConfig.java +++ b/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/config/ThreadPoolConfig.java @@ -53,7 +53,6 @@ public class ThreadPoolConfig { .awaitTerminationMillis(5000L) .taskDecorator(new TaskTraceBuilderHandler()) .build(); - return customExecutor; } @@ -69,12 +68,10 @@ public class ThreadPoolConfig { .waitForTasksToCompleteOnShutdown(true) .awaitTerminationMillis(5000L) /** - * 测试线程任务装饰器. - * 如果需要查看详情, 跳转 {@link TaskDecoratorTest} + * 上下文传递,测试用例:{@link TaskDecoratorTest} */ .taskDecorator(new TaskDecoratorTest.ContextCopyingDecorator()) .build(); - return produceExecutor; } diff --git a/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/handler/ErrorLogRejectedExecutionHandler.java b/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/handler/ErrorLogRejectedExecutionHandler.java index 3b31204d..67a63b5f 100644 --- a/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/handler/ErrorLogRejectedExecutionHandler.java +++ b/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/handler/ErrorLogRejectedExecutionHandler.java @@ -49,7 +49,5 @@ public class ErrorLogRejectedExecutionHandler implements CustomRejectedExecution Logger logger = LoggerFactory.getLogger(this.getClass()); logger.error("线程池抛出拒绝策略."); } - } - } diff --git a/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/handler/TaskTraceBuilderHandler.java b/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/handler/TaskTraceBuilderHandler.java index 21b7ac15..e6f89c15 100644 --- a/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/handler/TaskTraceBuilderHandler.java +++ b/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/handler/TaskTraceBuilderHandler.java @@ -34,7 +34,6 @@ public final class TaskTraceBuilderHandler implements TaskDecorator { @Override public Runnable decorate(Runnable runnable) { String executeTimeoutTrace = MDC.get(EXECUTE_TIMEOUT_TRACE); - Runnable taskRun = () -> { if (StringUtil.isNotBlank(executeTimeoutTrace)) { MDC.put(EXECUTE_TIMEOUT_TRACE, executeTimeoutTrace); @@ -42,8 +41,6 @@ public final class TaskTraceBuilderHandler implements TaskDecorator { runnable.run(); // 此处不用进行清理操作, 统一在线程任务执行后清理 }; - return taskRun; } - } diff --git a/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/inittest/AlarmSendMessageTest.java b/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/inittest/AlarmSendMessageTest.java index c01f4098..394b37cc 100644 --- a/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/inittest/AlarmSendMessageTest.java +++ b/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/inittest/AlarmSendMessageTest.java @@ -56,5 +56,4 @@ public class AlarmSendMessageTest { } }, 3, 1, TimeUnit.SECONDS); } - } diff --git a/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/inittest/RunStateHandlerTest.java b/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/inittest/RunStateHandlerTest.java index 14132171..5a0789e5 100644 --- a/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/inittest/RunStateHandlerTest.java +++ b/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/inittest/RunStateHandlerTest.java @@ -69,7 +69,6 @@ public class RunStateHandlerTest { // 启动动态线程池模拟运行任务 runTask(messageConsumeDynamicThreadPool); - // 启动动态线程池模拟运行任务 runTask(messageProduceDynamicThreadPool); } @@ -102,11 +101,8 @@ public class RunStateHandlerTest { } catch (Exception ex) { // ignore } - ThreadUtil.sleep(500); } - }); } - } diff --git a/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/inittest/TaskDecoratorTest.java b/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/inittest/TaskDecoratorTest.java index c8f3a820..05739ab9 100644 --- a/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/inittest/TaskDecoratorTest.java +++ b/hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/inittest/TaskDecoratorTest.java @@ -74,7 +74,6 @@ public class TaskDecoratorTest { log.info("通过 taskDecorator MDC 传递上下文 :: {}", MDC.get(PLACEHOLDER)); }); }); - } public static class ContextCopyingDecorator implements TaskDecorator { @@ -93,5 +92,4 @@ public class TaskDecoratorTest { }; } } - }