andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fixed compilation errors in VirtualExecutorService

Browse Source
This commit is contained in:
Trustin Lee 2009-06-03 07:48:23 +00:00
parent 5f27babff4
commit 2100462235
1 changed files with 0 additions and 74 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

74
src/main/java/org/jboss/netty/util/VirtualExecutorService.java
View File

@ -22,20 +22,15 @@
*/
package org.jboss.netty.util;
import java.util.Collection;
import java.util.Collections;
import java.util.IdentityHashMap;
import java.util.List;
import java.util.Set;
import java.util.concurrent.AbstractExecutorService;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Future;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import org.jboss.netty.util.internal.MapBackedSet;
@ -156,75 +151,6 @@ public class VirtualExecutorService extends AbstractExecutorService {
}
}
@Override
public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
throws InterruptedException {
if (s != null) {
return s.invokeAll(tasks);
} else {
return super.invokeAll(tasks);
}
}
@Override
public <T> List<Future<T>> invokeAll(
Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
throws InterruptedException {
if (s != null) {
return s.invokeAll(tasks, timeout, unit);
} else {
return super.invokeAll(tasks, timeout, unit);
}
}
@Override
public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
throws InterruptedException, ExecutionException {
if (s != null) {
return s.invokeAny(tasks);
} else {
return super.invokeAny(tasks);
}
}
@Override
public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
long timeout, TimeUnit unit) throws InterruptedException,
ExecutionException, TimeoutException {
if (s != null) {
return s.invokeAny(tasks, timeout, unit);
} else {
return super.invokeAny(tasks, timeout, unit);
}
}
@Override
public <T> Future<T> submit(Callable<T> task) {
if (s != null) {
return s.submit(task);
} else {
return super.submit(task);
}
}
@Override
public Future<?> submit(Runnable task) {
if (s != null) {
return s.submit(task);
} else {
return super.submit(task);
}
}
@Override
public <T> Future<T> submit(Runnable task, T result) {
if (s != null) {
return s.submit(task, result);
} else {
return super.submit(task, result);
}
}
public void execute(Runnable command) {
if (command == null) {
throw new NullPointerException("command");