From cb5aeb15cfa83329bc29f9088d41545646fc45b4 Mon Sep 17 00:00:00 2001
From: yuye <631941527@qq.com>
Date: Sun, 14 Apr 2019 15:06:48 +0800
Subject: [PATCH] =?UTF-8?q?:zap:=20=E6=B7=BB=E5=8A=A0=E7=BA=BF=E7=A8=8B?=
 =?UTF-8?q?=E6=B1=A0=E6=8B=92=E7=BB=9D=E7=AD=96=E7=95=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mars/netty/thread/MarsRejectedExecutionHandler.java    | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/mars-netty/src/main/java/com/mars/netty/thread/MarsRejectedExecutionHandler.java b/mars-netty/src/main/java/com/mars/netty/thread/MarsRejectedExecutionHandler.java
index 21f326b..f501064 100644
--- a/mars-netty/src/main/java/com/mars/netty/thread/MarsRejectedExecutionHandler.java
+++ b/mars-netty/src/main/java/com/mars/netty/thread/MarsRejectedExecutionHandler.java
@@ -1,5 +1,6 @@
 package com.mars.netty.thread;
 
+import com.mars.core.logger.MarsLogger;
 import com.mars.netty.util.ResponseUtil;
 
 import java.util.concurrent.RejectedExecutionHandler;
@@ -10,6 +11,8 @@ import java.util.concurrent.ThreadPoolExecutor;
  */
 public class MarsRejectedExecutionHandler implements RejectedExecutionHandler {
 
+    private MarsLogger marsLogger = MarsLogger.getLogger(MarsRejectedExecutionHandler.class);
+
     /**
      * 拒绝策略
      * @param r
@@ -17,9 +20,13 @@ public class MarsRejectedExecutionHandler implements RejectedExecutionHandler {
      */
     @Override
     public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
+        marsLogger.info("拒绝策略开始执行");
         if(r instanceof RequestThread){
             RequestThread requestThread = (RequestThread)r;
             ResponseUtil.sendForBidden(requestThread.getCtx(),"当前请求太多，请稍后访问");
+            marsLogger.info("拒绝策略开始结束");
+            return;
         }
+        marsLogger.info("拒绝策略没有成功执行");
     }
 }