class com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService extends java.util.concurrent.AbstractExecutorService implements com.google.common.util.concurrent.ListeningScheduledExecutorService
{
private final com.google.common.util.concurrent.ListeningExecutorService delegate;
void <init>()
{
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
com.google.common.util.concurrent.ListeningExecutorService v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
specialinvoke v.<java.util.concurrent.AbstractExecutorService: void <init>()>();
v = staticinvoke <com.google.common.util.concurrent.MoreExecutors: com.google.common.util.concurrent.ListeningExecutorService newDirectExecutorService()>();
v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService: com.google.common.util.concurrent.ListeningExecutorService delegate> = v;
return;
}
public void shutdown()
{
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
com.google.common.util.concurrent.ListeningExecutorService v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v = v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService: com.google.common.util.concurrent.ListeningExecutorService delegate>;
interfaceinvoke v.<com.google.common.util.concurrent.ListeningExecutorService: void shutdown()>();
return;
}
public java.util.List shutdownNow()
{
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
java.util.List v;
com.google.common.util.concurrent.ListeningExecutorService v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v = v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService: com.google.common.util.concurrent.ListeningExecutorService delegate>;
v = interfaceinvoke v.<com.google.common.util.concurrent.ListeningExecutorService: java.util.List shutdownNow()>();
return v;
}
public boolean isShutdown()
{
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
boolean v;
com.google.common.util.concurrent.ListeningExecutorService v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v = v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService: com.google.common.util.concurrent.ListeningExecutorService delegate>;
v = interfaceinvoke v.<com.google.common.util.concurrent.ListeningExecutorService: boolean isShutdown()>();
return v;
}
public boolean isTerminated()
{
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
boolean v;
com.google.common.util.concurrent.ListeningExecutorService v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v = v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService: com.google.common.util.concurrent.ListeningExecutorService delegate>;
v = interfaceinvoke v.<com.google.common.util.concurrent.ListeningExecutorService: boolean isTerminated()>();
return v;
}
public boolean awaitTermination(long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
long v;
boolean v;
com.google.common.util.concurrent.ListeningExecutorService v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "unit must not be null!");
v = v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService: com.google.common.util.concurrent.ListeningExecutorService delegate>;
v = interfaceinvoke v.<com.google.common.util.concurrent.ListeningExecutorService: boolean awaitTermination(long,java.util.concurrent.TimeUnit)>(v, v);
return v;
}
public com.google.common.util.concurrent.ListenableFuture submit(java.util.concurrent.Callable)
{
com.google.common.util.concurrent.ListenableFuture v;
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
java.util.concurrent.Callable v;
com.google.common.util.concurrent.ListeningExecutorService v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v := @parameter: java.util.concurrent.Callable;
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "task must not be null!");
v = v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService: com.google.common.util.concurrent.ListeningExecutorService delegate>;
v = interfaceinvoke v.<com.google.common.util.concurrent.ListeningExecutorService: com.google.common.util.concurrent.ListenableFuture submit(java.util.concurrent.Callable)>(v);
return v;
}
public com.google.common.util.concurrent.ListenableFuture submit(java.lang.Runnable, java.lang.Object)
{
com.google.common.util.concurrent.ListenableFuture v;
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
java.lang.Object v;
java.lang.Runnable v;
com.google.common.util.concurrent.ListeningExecutorService v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v := @parameter: java.lang.Runnable;
v := @parameter: java.lang.Object;
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "task must not be null!");
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "result must not be null!");
v = v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService: com.google.common.util.concurrent.ListeningExecutorService delegate>;
v = interfaceinvoke v.<com.google.common.util.concurrent.ListeningExecutorService: com.google.common.util.concurrent.ListenableFuture submit(java.lang.Runnable,java.lang.Object)>(v, v);
return v;
}
public com.google.common.util.concurrent.ListenableFuture submit(java.lang.Runnable)
{
com.google.common.util.concurrent.ListenableFuture v;
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
java.lang.Runnable v;
com.google.common.util.concurrent.ListeningExecutorService v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v := @parameter: java.lang.Runnable;
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "task must not be null!");
v = v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService: com.google.common.util.concurrent.ListeningExecutorService delegate>;
v = interfaceinvoke v.<com.google.common.util.concurrent.ListeningExecutorService: com.google.common.util.concurrent.ListenableFuture submit(java.lang.Runnable)>(v);
return v;
}
public java.util.List invokeAll(java.util.Collection) throws java.lang.InterruptedException
{
java.util.List v;
java.util.Collection v;
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
com.google.common.util.concurrent.ListeningExecutorService v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v := @parameter: java.util.Collection;
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "tasks must not be null!");
v = v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService: com.google.common.util.concurrent.ListeningExecutorService delegate>;
v = interfaceinvoke v.<com.google.common.util.concurrent.ListeningExecutorService: java.util.List invokeAll(java.util.Collection)>(v);
return v;
}
public 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;
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
long v;
com.google.common.util.concurrent.ListeningExecutorService v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v := @parameter: java.util.Collection;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "tasks must not be null!");
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "unit must not be null!");
v = v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService: com.google.common.util.concurrent.ListeningExecutorService delegate>;
v = interfaceinvoke v.<com.google.common.util.concurrent.ListeningExecutorService: java.util.List invokeAll(java.util.Collection,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public java.lang.Object invokeAny(java.util.Collection) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
{
java.util.Collection v;
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
java.lang.Object v;
com.google.common.util.concurrent.ListeningExecutorService v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v := @parameter: java.util.Collection;
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "tasks must not be null!");
v = v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService: com.google.common.util.concurrent.ListeningExecutorService delegate>;
v = interfaceinvoke v.<com.google.common.util.concurrent.ListeningExecutorService: java.lang.Object invokeAny(java.util.Collection)>(v);
return v;
}
public 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;
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
java.lang.Object v;
long v;
com.google.common.util.concurrent.ListeningExecutorService v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v := @parameter: java.util.Collection;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "tasks must not be null!");
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "unit must not be null!");
v = v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService: com.google.common.util.concurrent.ListeningExecutorService delegate>;
v = interfaceinvoke v.<com.google.common.util.concurrent.ListeningExecutorService: java.lang.Object invokeAny(java.util.Collection,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public void execute(java.lang.Runnable)
{
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
java.lang.Runnable v;
com.google.common.util.concurrent.ListeningExecutorService v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v := @parameter: java.lang.Runnable;
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "command must not be null!");
v = v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService: com.google.common.util.concurrent.ListeningExecutorService delegate>;
interfaceinvoke v.<com.google.common.util.concurrent.ListeningExecutorService: void execute(java.lang.Runnable)>(v);
return;
}
public com.google.common.util.concurrent.ListenableScheduledFuture schedule(java.lang.Runnable, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
com.google.common.util.concurrent.ListenableScheduledFuture v;
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
java.util.concurrent.Callable v;
long v;
java.lang.Runnable v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v := @parameter: java.lang.Runnable;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "command must not be null");
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "unit must not be null!");
v = staticinvoke <java.util.concurrent.Executors: java.util.concurrent.Callable callable(java.lang.Runnable)>(v);
v = virtualinvoke v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService: com.google.common.util.concurrent.ListenableScheduledFuture schedule(java.util.concurrent.Callable,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public com.google.common.util.concurrent.ListenableScheduledFuture schedule(java.util.concurrent.Callable, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
com.google.common.util.concurrent.ListenableFuture v;
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
java.util.concurrent.Callable v;
long v;
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService$ImmediateScheduledFuture v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v := @parameter: java.util.concurrent.Callable;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "callable must not be null!");
staticinvoke <com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "unit must not be null!");
v = virtualinvoke v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService: com.google.common.util.concurrent.ListenableFuture submit(java.util.concurrent.Callable)>(v);
v = new com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService$ImmediateScheduledFuture;
specialinvoke v.<com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService$ImmediateScheduledFuture: void <init>(com.google.common.util.concurrent.ListenableFuture)>(v);
return v;
}
public com.google.common.util.concurrent.ListenableScheduledFuture scheduleAtFixedRate(java.lang.Runnable, long, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
java.lang.UnsupportedOperationException v;
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
long v, v;
java.lang.Runnable v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v := @parameter: java.lang.Runnable;
v := @parameter: long;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("scheduleAtFixedRate is not supported.");
throw v;
}
public com.google.common.util.concurrent.ListenableScheduledFuture scheduleWithFixedDelay(java.lang.Runnable, long, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
java.lang.UnsupportedOperationException v;
com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService v;
long v, v;
java.lang.Runnable v;
v := @this: com.google.common.util.concurrent.testing.SameThreadScheduledExecutorService;
v := @parameter: java.lang.Runnable;
v := @parameter: long;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("scheduleWithFixedDelay is not supported.");
throw v;
}
}