You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jena.apache.org by an...@apache.org on 2011/11/07 21:23:01 UTC

svn commit: r1198917 - /incubator/jena/Jena2/TDB/trunk/src/test/java/com/hp/hpl/jena/tdb/transaction/T_TransSystem.java

Author: andy
Date: Mon Nov  7 20:23:01 2011
New Revision: 1198917

URL: http://svn.apache.org/viewvc?rev=1198917&view=rev
Log: (empty)

Modified:
    incubator/jena/Jena2/TDB/trunk/src/test/java/com/hp/hpl/jena/tdb/transaction/T_TransSystem.java

Modified: incubator/jena/Jena2/TDB/trunk/src/test/java/com/hp/hpl/jena/tdb/transaction/T_TransSystem.java
URL: http://svn.apache.org/viewvc/incubator/jena/Jena2/TDB/trunk/src/test/java/com/hp/hpl/jena/tdb/transaction/T_TransSystem.java?rev=1198917&r1=1198916&r2=1198917&view=diff
==============================================================================
--- incubator/jena/Jena2/TDB/trunk/src/test/java/com/hp/hpl/jena/tdb/transaction/T_TransSystem.java (original)
+++ incubator/jena/Jena2/TDB/trunk/src/test/java/com/hp/hpl/jena/tdb/transaction/T_TransSystem.java Mon Nov  7 20:23:01 2011
@@ -87,6 +87,8 @@ public class T_TransSystem
     static final int writerAbortSeqRepeats  = 4 ;
     static final int writerCommitSeqRepeats = 4 ;
     static final int writerMaxPause         = 20 ;
+
+    private ExecutorService execService = Executors.newCachedThreadPool() ;
     
     public static void main(String...args)
     {
@@ -359,10 +361,9 @@ public class T_TransSystem
         for ( int i = 0 ; i < numTasks ; i++ )
         {
             execService.submit(proc) ;
-            // This creates an lot of threads, which aren't collected up.
-            // But the thread is named.
 //            counter++ ;
-//            new Thread(new Callable2Runnable<T>(proc), label+counter).start() ;
+//            Thread t = new Thread(new Callable2Runnable<T>(proc), label+counter) ;
+//            t.start();
         }
     }
 
@@ -412,8 +413,6 @@ public class T_TransSystem
         System.out.printf(string, args) ;
     }
 
-    private ExecutorService execService = Executors.newCachedThreadPool() ;
-
     static Quad q  = SSE.parseQuad("(_ <s> <p> <o>) ") ;
 
     static Quad q1 = SSE.parseQuad("(_ <s> <p> <o1>)") ;