* @param listenableFutureExecutor the executor used to run listener callbacks asynchronously.
* If null, no executor is used.
*/
- public AsyncNotifyingListeningExecutorService( final ExecutorService delegate,
- @Nullable final Executor listenableFutureExecutor ) {
- this.delegate = Preconditions.checkNotNull( delegate );
+ public AsyncNotifyingListeningExecutorService(final ExecutorService delegate,
+ @Nullable final Executor listenableFutureExecutor) {
+ this.delegate = Preconditions.checkNotNull(delegate);
this.listenableFutureExecutor = listenableFutureExecutor;
}
*
* @param task the Callable to execute
*/
- private <T> AsyncNotifyingListenableFutureTask<T> newFutureTask( final Callable<T> task ) {
- return AsyncNotifyingListenableFutureTask.create( task, listenableFutureExecutor );
+ private <T> AsyncNotifyingListenableFutureTask<T> newFutureTask(final Callable<T> task) {
+ return AsyncNotifyingListenableFutureTask.create(task, listenableFutureExecutor);
}
/**
*
* @param task the Runnable to execute
*/
- private <T> AsyncNotifyingListenableFutureTask<T> newFutureTask( final Runnable task, final T result ) {
- return AsyncNotifyingListenableFutureTask.create( task, result, listenableFutureExecutor );
+ private <T> AsyncNotifyingListenableFutureTask<T> newFutureTask(final Runnable task, final T result) {
+ return AsyncNotifyingListenableFutureTask.create(task, result, listenableFutureExecutor);
}
/**
}
@Override
- public boolean awaitTermination( final long timeout, @Nonnull final TimeUnit unit ) throws InterruptedException {
- return delegate.awaitTermination( timeout, unit );
+ public boolean awaitTermination(final long timeout, @Nonnull final TimeUnit unit) throws InterruptedException {
+ return delegate.awaitTermination(timeout, unit);
}
@Override
}
@Override
- public void execute( @Nonnull final Runnable command ) {
- delegate.execute( command );
+ public void execute(@Nonnull final Runnable command) {
+ delegate.execute(command);
}
@Nonnull
@Override
- public <T> ListenableFuture<T> submit( final Callable<T> task ) {
- AsyncNotifyingListenableFutureTask<T> futureTask = newFutureTask( task );
- delegate.execute( futureTask );
+ public <T> ListenableFuture<T> submit(final Callable<T> task) {
+ AsyncNotifyingListenableFutureTask<T> futureTask = newFutureTask(task);
+ delegate.execute(futureTask);
return futureTask;
}
@Nonnull
@Override
- public ListenableFuture<?> submit( final Runnable task ) {
- AsyncNotifyingListenableFutureTask<Void> futureTask = newFutureTask( task, null );
- delegate.execute( futureTask );
+ public ListenableFuture<?> submit(final Runnable task) {
+ AsyncNotifyingListenableFutureTask<Void> futureTask = newFutureTask(task, null);
+ delegate.execute(futureTask);
return futureTask;
}
@Nonnull
@Override
- public <T> ListenableFuture<T> submit( final Runnable task, final T result ) {
- AsyncNotifyingListenableFutureTask<T> futureTask = newFutureTask( task, result );
- delegate.execute( futureTask );
+ public <T> ListenableFuture<T> submit(final Runnable task, final T result) {
+ AsyncNotifyingListenableFutureTask<T> futureTask = newFutureTask(task, result);
+ delegate.execute(futureTask);
return futureTask;
}
- protected ToStringHelper addToStringAttributes( final ToStringHelper toStringHelper ) {
+ protected ToStringHelper addToStringAttributes(final ToStringHelper toStringHelper) {
return toStringHelper;
}
@Override
public final String toString() {
- return addToStringAttributes( MoreObjects.toStringHelper( this )
- .add( "delegate", delegate ) ).toString();
+ return addToStringAttributes(MoreObjects.toStringHelper(this)
+ .add("delegate", delegate)).toString();
}
}