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);
}