From 2b2103170bfeed6921e2fa4fcab3e152ad577342 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Thu, 25 Apr 2019 10:02:04 +0800 Subject: [PATCH] =?UTF-8?q?[=E6=A3=80=E6=9F=A5=E7=BA=BF=E7=A8=8B=E6=95=B0]?= =?UTF-8?q?[=E4=BF=AE=E6=94=B9]:=E6=89=93=E5=8D=B0=E5=8D=A0=E7=94=A8?= =?UTF-8?q?=E7=BA=BF=E7=A8=8B=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/WechatCalllbackController.java | 20 +++++++++++++++++++ 1 file changed, 20 insertions(+) diff --git a/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java b/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java index b6c886f..abd98a9 100644 --- a/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java +++ b/mlWechatOpen/src/main/java/com/iformall/controller/WechatCalllbackController.java @@ -283,10 +283,12 @@ public class WechatCalllbackController extends BaseController { return; } } else { + getThreadCount( 0 ); // 公众号 WxMpService mpService = openService.getWxOpenComponentService().getWxMpServiceByAppid(appId); try { WxMpXmlOutMessage outMessage = mpManager.getRouter(mpService).route(inMessage); + getThreadCount( 1 ); if (outMessage == null) { this.logger.info("2 return: success"); printWriter.print("success"); @@ -307,6 +309,24 @@ public class WechatCalllbackController extends BaseController { printWriter.close(); } + private void getThreadCount( int i) { + ThreadGroup group = Thread.currentThread().getThreadGroup(); + ThreadGroup topGroup = group; + // 遍历线程组树,获取根线程组 + while (group != null) { + topGroup = group; + group = group.getParent(); + } + // 激活的线程数加倍 + int estimatedSize = topGroup.activeCount() * 2; + Thread[] slackList = new Thread[estimatedSize]; + // 获取根线程组的所有线程 + int actualSize = topGroup.enumerate(slackList); + // copy into a list that is the exact size + logger.info("Thread list size == " + i + " : " + actualSize); + + } + private void updateAuditStatus(String appId, boolean success, String reason) {