[jboss-cvs] JBossAS SVN: r109090 - in projects/jboss-jca/branches/performance/pojos/src/main: resources and 1 other directory.

[jboss-cvs-commits at lists.jboss.org]

Author: jesper.pedersen
Date: 2010-11-03 09:34:53 -0400 (Wed, 03 Nov 2010)
New Revision: 109090

Modified:
   projects/jboss-jca/branches/performance/pojos/src/main/java/org/jboss/jca/performance/pojos/DatabaseTester.java
   projects/jboss-jca/branches/performance/pojos/src/main/resources/dbtester.xml
Log:
Add MaxThreads property

Modified: projects/jboss-jca/branches/performance/pojos/src/main/java/org/jboss/jca/performance/pojos/DatabaseTester.java
===================================================================
--- projects/jboss-jca/branches/performance/pojos/src/main/java/org/jboss/jca/performance/pojos/DatabaseTester.java	2010-11-03 12:24:55 UTC (rev 109089)
+++ projects/jboss-jca/branches/performance/pojos/src/main/java/org/jboss/jca/performance/pojos/DatabaseTester.java	2010-11-03 13:34:53 UTC (rev 109090)
@@ -55,6 +55,9 @@
    /** Multithreaded execution */
    private boolean multiThreaded;
 
+   /** Max number of threads */
+   private int maxThreads;
+
    /** The JNDI for the datasource */
    private String dbJndiName;
 
@@ -70,6 +73,7 @@
    public DatabaseTester()
    {
       this.multiThreaded = false;
+      this.maxThreads = 100;
       this.dbJndiName = null;
       this.iterations = 1;
       this.sqls = null;
@@ -85,6 +89,15 @@
    }
 
    /**
+    * Set the max number of threads
+    * @param v The value
+    */
+   public void setMaxThreads(int v)
+   {
+      this.maxThreads = v;
+   }
+
+   /**
     * Set the datasource JNDI name
     * @param v The value
     */
@@ -128,7 +141,7 @@
             CountDownLatch cdl = new CountDownLatch(iterations);
 
             BlockingQueue<Runnable> threadPoolQueue = new SynchronousQueue<Runnable>(true);
-            ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors(), Integer.MAX_VALUE,
+            ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors(), maxThreads,
                                                                            60, TimeUnit.SECONDS,
                                                                            threadPoolQueue);
 

Modified: projects/jboss-jca/branches/performance/pojos/src/main/resources/dbtester.xml
===================================================================
--- projects/jboss-jca/branches/performance/pojos/src/main/resources/dbtester.xml	2010-11-03 12:24:55 UTC (rev 109089)
+++ projects/jboss-jca/branches/performance/pojos/src/main/resources/dbtester.xml	2010-11-03 13:34:53 UTC (rev 109090)
@@ -5,6 +5,7 @@
   <bean name="DatabaseTester" 
         class="org.jboss.jca.performance.pojos.DatabaseTester">
     <property name="MultiThreaded">true</property>
+    <property name="MaxThreads">1000</property>
     <property name="DbJndiName">java:/H2XADS</property>
     <property name="Iterations">1000</property>
     <property name="Sqls">