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); }