abstract class oadd.com.google.common.util.concurrent.WrappingExecutorService extends java.lang.Object implements java.util.concurrent.ExecutorService
{
private final java.util.concurrent.ExecutorService delegate;
protected void <init>(java.util.concurrent.ExecutorService)
{
java.lang.Object v;
java.util.concurrent.ExecutorService v;
oadd.com.google.common.util.concurrent.WrappingExecutorService v;
v := @this: oadd.com.google.common.util.concurrent.WrappingExecutorService;
v := @parameter: java.util.concurrent.ExecutorService;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <oadd.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.ExecutorService delegate> = v;
return;
}
protected abstract java.util.concurrent.Callable wrapTask(java.util.concurrent.Callable);
protected java.lang.Runnable wrapTask(java.lang.Runnable)
{
oadd.com.google.common.util.concurrent.WrappingExecutorService$1 v;
oadd.com.google.common.util.concurrent.WrappingExecutorService v;
java.util.concurrent.Callable v, v;
java.lang.Runnable v;
v := @this: oadd.com.google.common.util.concurrent.WrappingExecutorService;
v := @parameter: java.lang.Runnable;
v = staticinvoke <java.util.concurrent.Executors: java.util.concurrent.Callable callable(java.lang.Runnable,java.lang.Object)>(v, null);
v = virtualinvoke v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.Callable wrapTask(java.util.concurrent.Callable)>(v);
v = new oadd.com.google.common.util.concurrent.WrappingExecutorService$1;
specialinvoke v.<oadd.com.google.common.util.concurrent.WrappingExecutorService$1: void <init>(oadd.com.google.common.util.concurrent.WrappingExecutorService,java.util.concurrent.Callable)>(v, v);
return v;
}
private oadd.com.google.common.collect.ImmutableList wrapTasks(java.util.Collection)
{
java.util.Iterator v;
java.util.Collection v;
java.util.concurrent.Callable v;
oadd.com.google.common.collect.ImmutableList$Builder v;
oadd.com.google.common.util.concurrent.WrappingExecutorService v;
oadd.com.google.common.collect.ImmutableList v;
java.lang.Object v;
boolean v;
v := @this: oadd.com.google.common.util.concurrent.WrappingExecutorService;
v := @parameter: java.util.Collection;
v = staticinvoke <oadd.com.google.common.collect.ImmutableList: oadd.com.google.common.collect.ImmutableList$Builder builder()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.Callable wrapTask(java.util.concurrent.Callable)>(v);
virtualinvoke v.<oadd.com.google.common.collect.ImmutableList$Builder: oadd.com.google.common.collect.ImmutableList$Builder add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<oadd.com.google.common.collect.ImmutableList$Builder: oadd.com.google.common.collect.ImmutableList build()>();
return v;
}
public final void execute(java.lang.Runnable)
{
oadd.com.google.common.util.concurrent.WrappingExecutorService v;
java.lang.Runnable v, v;
java.util.concurrent.ExecutorService v;
v := @this: oadd.com.google.common.util.concurrent.WrappingExecutorService;
v := @parameter: java.lang.Runnable;
v = v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.ExecutorService delegate>;
v = virtualinvoke v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.lang.Runnable wrapTask(java.lang.Runnable)>(v);
interfaceinvoke v.<java.util.concurrent.ExecutorService: void execute(java.lang.Runnable)>(v);
return;
}
public final java.util.concurrent.Future submit(java.util.concurrent.Callable)
{
java.util.concurrent.Future v;
oadd.com.google.common.util.concurrent.WrappingExecutorService v;
java.lang.Object v;
java.util.concurrent.Callable v, v;
java.util.concurrent.ExecutorService v;
v := @this: oadd.com.google.common.util.concurrent.WrappingExecutorService;
v := @parameter: java.util.concurrent.Callable;
v = v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.ExecutorService delegate>;
v = staticinvoke <oadd.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v = virtualinvoke v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.Callable wrapTask(java.util.concurrent.Callable)>(v);
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.concurrent.Future submit(java.util.concurrent.Callable)>(v);
return v;
}
public final java.util.concurrent.Future submit(java.lang.Runnable)
{
java.util.concurrent.Future v;
oadd.com.google.common.util.concurrent.WrappingExecutorService v;
java.lang.Runnable v, v;
java.util.concurrent.ExecutorService v;
v := @this: oadd.com.google.common.util.concurrent.WrappingExecutorService;
v := @parameter: java.lang.Runnable;
v = v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.ExecutorService delegate>;
v = virtualinvoke v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.lang.Runnable wrapTask(java.lang.Runnable)>(v);
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.concurrent.Future submit(java.lang.Runnable)>(v);
return v;
}
public final java.util.concurrent.Future submit(java.lang.Runnable, java.lang.Object)
{
java.util.concurrent.Future v;
oadd.com.google.common.util.concurrent.WrappingExecutorService v;
java.lang.Object v;
java.lang.Runnable v, v;
java.util.concurrent.ExecutorService v;
v := @this: oadd.com.google.common.util.concurrent.WrappingExecutorService;
v := @parameter: java.lang.Runnable;
v := @parameter: java.lang.Object;
v = v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.ExecutorService delegate>;
v = virtualinvoke v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.lang.Runnable wrapTask(java.lang.Runnable)>(v);
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.concurrent.Future submit(java.lang.Runnable,java.lang.Object)>(v, v);
return v;
}
public final java.util.List invokeAll(java.util.Collection) throws java.lang.InterruptedException
{
java.util.List v;
java.util.Collection v;
oadd.com.google.common.util.concurrent.WrappingExecutorService v;
oadd.com.google.common.collect.ImmutableList v;
java.util.concurrent.ExecutorService v;
v := @this: oadd.com.google.common.util.concurrent.WrappingExecutorService;
v := @parameter: java.util.Collection;
v = v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.ExecutorService delegate>;
v = specialinvoke v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: oadd.com.google.common.collect.ImmutableList wrapTasks(java.util.Collection)>(v);
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.List invokeAll(java.util.Collection)>(v);
return v;
}
public final java.util.List invokeAll(java.util.Collection, long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
java.util.List v;
java.util.Collection v;
oadd.com.google.common.util.concurrent.WrappingExecutorService v;
oadd.com.google.common.collect.ImmutableList v;
long v;
java.util.concurrent.ExecutorService v;
v := @this: oadd.com.google.common.util.concurrent.WrappingExecutorService;
v := @parameter: java.util.Collection;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.ExecutorService delegate>;
v = specialinvoke v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: oadd.com.google.common.collect.ImmutableList wrapTasks(java.util.Collection)>(v);
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.List invokeAll(java.util.Collection,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public final java.lang.Object invokeAny(java.util.Collection) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
{
java.util.Collection v;
oadd.com.google.common.util.concurrent.WrappingExecutorService v;
oadd.com.google.common.collect.ImmutableList v;
java.lang.Object v;
java.util.concurrent.ExecutorService v;
v := @this: oadd.com.google.common.util.concurrent.WrappingExecutorService;
v := @parameter: java.util.Collection;
v = v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.ExecutorService delegate>;
v = specialinvoke v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: oadd.com.google.common.collect.ImmutableList wrapTasks(java.util.Collection)>(v);
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.lang.Object invokeAny(java.util.Collection)>(v);
return v;
}
public final java.lang.Object invokeAny(java.util.Collection, long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException
{
java.util.concurrent.TimeUnit v;
java.util.Collection v;
oadd.com.google.common.util.concurrent.WrappingExecutorService v;
oadd.com.google.common.collect.ImmutableList v;
java.lang.Object v;
long v;
java.util.concurrent.ExecutorService v;
v := @this: oadd.com.google.common.util.concurrent.WrappingExecutorService;
v := @parameter: java.util.Collection;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.ExecutorService delegate>;
v = specialinvoke v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: oadd.com.google.common.collect.ImmutableList wrapTasks(java.util.Collection)>(v);
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.lang.Object invokeAny(java.util.Collection,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public final void shutdown()
{
java.util.concurrent.ExecutorService v;
oadd.com.google.common.util.concurrent.WrappingExecutorService v;
v := @this: oadd.com.google.common.util.concurrent.WrappingExecutorService;
v = v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.ExecutorService delegate>;
interfaceinvoke v.<java.util.concurrent.ExecutorService: void shutdown()>();
return;
}
public final java.util.List shutdownNow()
{
java.util.List v;
java.util.concurrent.ExecutorService v;
oadd.com.google.common.util.concurrent.WrappingExecutorService v;
v := @this: oadd.com.google.common.util.concurrent.WrappingExecutorService;
v = v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.ExecutorService delegate>;
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.List shutdownNow()>();
return v;
}
public final boolean isShutdown()
{
java.util.concurrent.ExecutorService v;
boolean v;
oadd.com.google.common.util.concurrent.WrappingExecutorService v;
v := @this: oadd.com.google.common.util.concurrent.WrappingExecutorService;
v = v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.ExecutorService delegate>;
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: boolean isShutdown()>();
return v;
}
public final boolean isTerminated()
{
java.util.concurrent.ExecutorService v;
boolean v;
oadd.com.google.common.util.concurrent.WrappingExecutorService v;
v := @this: oadd.com.google.common.util.concurrent.WrappingExecutorService;
v = v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.ExecutorService delegate>;
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: boolean isTerminated()>();
return v;
}
public final boolean awaitTermination(long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
oadd.com.google.common.util.concurrent.WrappingExecutorService v;
long v;
java.util.concurrent.ExecutorService v;
boolean v;
v := @this: oadd.com.google.common.util.concurrent.WrappingExecutorService;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<oadd.com.google.common.util.concurrent.WrappingExecutorService: java.util.concurrent.ExecutorService delegate>;
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: boolean awaitTermination(long,java.util.concurrent.TimeUnit)>(v, v);
return v;
}
}