From edd7812d3e1e9be9a64533e7b4a002428ce9b84f Mon Sep 17 00:00:00 2001 From: wenshao Date: Sat, 10 Sep 2011 13:38:22 +0000 Subject: [PATCH] =?UTF-8?q?=E8=87=AA=E5=B7=B1=E7=BB=B4=E6=8A=A4notEmptyWai?= =?UTF-8?q?tThreadCount=E8=AE=A1=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit git-svn-id: http://code.alibabatech.com/svn/druid/trunk@714 b9813039-fb51-4c41-a8b9-e21c2acb5095 --- src/main/java/com/alibaba/druid/pool/DruidDataSource.java | 4 ++++ .../java/com/alibaba/druid/pool/DruidDataSourceMBean.java | 2 ++ .../druid/bvt/pool/TestIdle3_Concurrent_Starvation.java | 2 +- 3 files changed, 7 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/alibaba/druid/pool/DruidDataSource.java b/src/main/java/com/alibaba/druid/pool/DruidDataSource.java index 6449698635..2b8f12708b 100644 --- a/src/main/java/com/alibaba/druid/pool/DruidDataSource.java +++ b/src/main/java/com/alibaba/druid/pool/DruidDataSource.java @@ -1009,6 +1009,10 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat return notEmptyWaitCount; } + public int getNotEmptyWaitThreadCount() { + return notEmptyWaitThreadCount; + } + public long getNotEmptySignalCount() { return notEmptySignalCount; } diff --git a/src/main/java/com/alibaba/druid/pool/DruidDataSourceMBean.java b/src/main/java/com/alibaba/druid/pool/DruidDataSourceMBean.java index 88a1e7c13a..479175f532 100644 --- a/src/main/java/com/alibaba/druid/pool/DruidDataSourceMBean.java +++ b/src/main/java/com/alibaba/druid/pool/DruidDataSourceMBean.java @@ -34,6 +34,8 @@ public interface DruidDataSourceMBean extends DruidAbstractDataSourceMBean { int getLockQueueLength(); long getNotEmptyWaitCount(); + + int getNotEmptyWaitThreadCount(); long getNotEmptySignalCount(); diff --git a/src/test/java/com/alibaba/druid/bvt/pool/TestIdle3_Concurrent_Starvation.java b/src/test/java/com/alibaba/druid/bvt/pool/TestIdle3_Concurrent_Starvation.java index 861c1052a0..b6adf3ad9d 100644 --- a/src/test/java/com/alibaba/druid/bvt/pool/TestIdle3_Concurrent_Starvation.java +++ b/src/test/java/com/alibaba/druid/bvt/pool/TestIdle3_Concurrent_Starvation.java @@ -62,7 +62,7 @@ public class TestIdle3_Concurrent_Starvation extends TestCase { } for (int i = 0; i < 1; ++i) { - final int threadCount = 10; + final int threadCount = 5; concurrent(threadCount); }