You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@shiro.apache.org by lh...@apache.org on 2010/02/22 20:30:40 UTC

svn commit: r915027 - /incubator/shiro/trunk/core/src/main/java/org/apache/shiro/concurrent/SubjectAwareExecutorService.java

Author: lhazlewood
Date: Mon Feb 22 19:30:40 2010
New Revision: 915027

URL: http://svn.apache.org/viewvc?rev=915027&view=rev
Log:
SHIRO-140: ugh - trying again by commenting out the invokeAll methods as well

Modified:
    incubator/shiro/trunk/core/src/main/java/org/apache/shiro/concurrent/SubjectAwareExecutorService.java

Modified: incubator/shiro/trunk/core/src/main/java/org/apache/shiro/concurrent/SubjectAwareExecutorService.java
URL: http://svn.apache.org/viewvc/incubator/shiro/trunk/core/src/main/java/org/apache/shiro/concurrent/SubjectAwareExecutorService.java?rev=915027&r1=915026&r2=915027&view=diff
==============================================================================
--- incubator/shiro/trunk/core/src/main/java/org/apache/shiro/concurrent/SubjectAwareExecutorService.java (original)
+++ incubator/shiro/trunk/core/src/main/java/org/apache/shiro/concurrent/SubjectAwareExecutorService.java Mon Feb 22 19:30:40 2010
@@ -63,7 +63,8 @@
 
     private ExecutorService targetExecutorService;
 
-    public SubjectAwareExecutorService(){}
+    public SubjectAwareExecutorService() {
+    }
 
     public SubjectAwareExecutorService(ExecutorService target) {
         setTargetExecutorService(target);
@@ -127,7 +128,7 @@
         return workItems;
     }
 
-    public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException {
+    /*public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException {
         Collection<Callable<T>> workItems = associateWithSubject(tasks);
         return this.targetExecutorService.invokeAll(workItems);
     }
@@ -138,7 +139,7 @@
         return this.targetExecutorService.invokeAll(workItems, timeout, unit);
     }
 
-    /*public <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException {
+    public <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException {
         Collection<Callable<T>> workItems = associateWithSubject(tasks);
         return this.targetExecutorService.invokeAny(workItems);
     }