[infinispan-commits] Infinispan SVN: r443 - trunk/core/src/main/java/org/infinispan/executors.

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-06-12 06:59:33 -0400 (Fri, 12 Jun 2009)
New Revision: 443

Modified:
   trunk/core/src/main/java/org/infinispan/executors/DefaultExecutorFactory.java
   trunk/core/src/main/java/org/infinispan/executors/DefaultScheduledExecutorFactory.java
Log:
Use a static counter for thread IDs

Modified: trunk/core/src/main/java/org/infinispan/executors/DefaultExecutorFactory.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/executors/DefaultExecutorFactory.java	2009-06-12 10:57:48 UTC (rev 442)
+++ trunk/core/src/main/java/org/infinispan/executors/DefaultExecutorFactory.java	2009-06-12 10:59:33 UTC (rev 443)
@@ -17,12 +17,13 @@
  * @since 4.0
  */
 public class DefaultExecutorFactory implements ExecutorFactory {
+   private final static AtomicInteger counter = new AtomicInteger(0);
+
    public ExecutorService getExecutor(Properties p) {
       TypedProperties tp = TypedProperties.toTypedProperties(p);
       int maxThreads = tp.getIntProperty("maxThreads", 1);
       int queueSize = tp.getIntProperty("queueSize", 100000);
       final String threadNamePrefix = tp.getProperty("threadNamePrefix", "Thread");
-      final AtomicInteger counter = new AtomicInteger(0);
 
       ThreadFactory tf = new ThreadFactory() {
          public Thread newThread(Runnable r) {

Modified: trunk/core/src/main/java/org/infinispan/executors/DefaultScheduledExecutorFactory.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/executors/DefaultScheduledExecutorFactory.java	2009-06-12 10:57:48 UTC (rev 442)
+++ trunk/core/src/main/java/org/infinispan/executors/DefaultScheduledExecutorFactory.java	2009-06-12 10:59:33 UTC (rev 443)
@@ -13,9 +13,10 @@
  * @since 4.0
  */
 public class DefaultScheduledExecutorFactory implements ScheduledExecutorFactory {
+   final static AtomicInteger counter = new AtomicInteger(0);
+
    public ScheduledExecutorService getScheduledExecutor(Properties p) {
       final String threadNamePrefix = p.getProperty("threadNamePrefix", "ScheduledThread");
-      final AtomicInteger counter = new AtomicInteger(0);
       return Executors.newSingleThreadScheduledExecutor(new ThreadFactory() {
          public Thread newThread(Runnable r) {
             Thread th = new Thread(r, threadNamePrefix + "-" + counter.getAndIncrement());