svn commit: r1348730 - /openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/Core.java

[rmannibucau]

Author: rmannibucau
Date: Mon Jun 11 07:33:47 2012
New Revision: 1348730

URL: http://svn.apache.org/viewvc?rev=1348730&view=rev
Log:
better thread number (ready for java 7)

Modified:
    
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/Core.java

Modified: 
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/Core.java
URL: 
http://svn.apache.org/viewvc/openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/Core.java?rev=1348730&r1=1348729&r2=1348730&view=diff
==============================================================================
--- 
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/Core.java
 (original)
+++ 
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/Core.java
 Mon Jun 11 07:33:47 2012
@@ -93,7 +93,7 @@ public class Core {
         };
         preloadLogger.start();
 
-        final int permits = 2;
+        final int permits = Runtime.getRuntime().availableProcessors() + 1;
         final Semaphore semaphore = new Semaphore(permits);
         final ClassLoader loader = OpenEjbContainer.class.getClassLoader();
 
@@ -106,6 +106,7 @@ public class Core {
                         try {
                             Class.forName(className, true, loader);
                         } catch (Throwable e) {
+                            // no-op
                         } finally {
                             semaphore.release();
                         }
@@ -126,29 +127,5 @@ public class Core {
         }
     }
 
-    public static void warmup(){}
-
-    public static class Parallel {
-
-        public static void exec(Runnable... runnables) {
-            final int permits = 2;
-            final Semaphore semaphore = new Semaphore(permits);
-
-            for (Runnable runnable : runnables) {
-                try {
-                    semaphore.acquire();
-                    final Thread thread = new Thread();
-                    thread.setDaemon(true);
-                    thread.start();
-                } catch (InterruptedException e) {
-                    Thread.interrupted();
-                }
-            }
-            try {
-                semaphore.acquire(permits);
-            } catch (InterruptedException e) {
-                Thread.interrupted();
-            }
-        }
-    }
+    public static void warmup() {}
 }