|
Java example source code file (TrustedListenableFutureTask.java)
This example Java source code file (TrustedListenableFutureTask.java) is included in the alvinalexander.com
"Java Source Code
Warehouse" project. The intent of this project is to help you "Learn
Java by Example" TM.
Learn more about this Java project at its project page.
The TrustedListenableFutureTask.java Java example source code
/*
* Copyright (C) 2014 The Guava Authors
*
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
* in compliance with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software distributed under the License
* is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
*/
package com.google.common.util.concurrent;
import static com.google.common.base.Preconditions.checkNotNull;
import com.google.common.annotations.GwtCompatible;
import com.google.common.annotations.GwtIncompatible;
import com.google.j2objc.annotations.WeakOuter;
import java.util.concurrent.Callable;
import java.util.concurrent.Executors;
import java.util.concurrent.RunnableFuture;
import javax.annotation.Nullable;
/**
* A {@link RunnableFuture} that also implements the {@link ListenableFuture} interface.
*
* <p>This should be used in preference to {@link ListenableFutureTask} when possible for
* performance reasons.
*/
@GwtCompatible
class TrustedListenableFutureTask<V> extends AbstractFuture.TrustedFuture
implements RunnableFuture<V> {
/**
* Creates a {@code ListenableFutureTask} that will upon running, execute the given
* {@code Callable}.
*
* @param callable the callable task
*/
static <V> TrustedListenableFutureTask create(Callable callable) {
return new TrustedListenableFutureTask<V>(callable);
}
/**
* Creates a {@code ListenableFutureTask} that will upon running, execute the given
* {@code Runnable}, and arrange that {@code get} will return the given result on successful
* completion.
*
* @param runnable the runnable task
* @param result the result to return on successful completion. If you don't need a particular
* result, consider using constructions of the form:
* {@code ListenableFuture<?> f = ListenableFutureTask.create(runnable,
* null)}
*/
static <V> TrustedListenableFutureTask create(Runnable runnable, @Nullable V result) {
return new TrustedListenableFutureTask<V>(Executors.callable(runnable, result));
}
private TrustedFutureInterruptibleTask task;
TrustedListenableFutureTask(Callable<V> callable) {
this.task = new TrustedFutureInterruptibleTask(callable);
}
@Override
public void run() {
TrustedFutureInterruptibleTask localTask = task;
if (localTask != null) {
localTask.run();
}
}
@Override
protected final void afterDone() {
super.afterDone();
// Free all resources associated with the running task
this.task = null;
}
@GwtIncompatible // Interruption not supported
@Override
protected final void interruptTask() {
TrustedFutureInterruptibleTask localTask = task;
if (localTask != null) {
localTask.interruptTask();
}
}
@Override
public String toString() {
return super.toString() + " (delegate = " + task + ")";
}
@WeakOuter
private final class TrustedFutureInterruptibleTask extends InterruptibleTask {
private final Callable<V> callable;
TrustedFutureInterruptibleTask(Callable<V> callable) {
this.callable = checkNotNull(callable);
}
@Override
void runInterruptibly() {
// Ensure we haven't been cancelled or already run.
if (!isDone()) {
try {
set(callable.call());
} catch (Throwable t) {
setException(t);
}
}
}
@Override
boolean wasInterrupted() {
return TrustedListenableFutureTask.this.wasInterrupted();
}
@Override
public String toString() {
return callable.toString();
}
}
}
Other Java examples (source code examples)
Here is a short list of links related to this Java TrustedListenableFutureTask.java source code file:
|