本文整理了Java中com.google.common.util.concurrent.AbstractFuture.cancel()
方法的一些代码示例,展示了AbstractFuture.cancel()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。AbstractFuture.cancel()
方法的具体详情如下:
包路径:com.google.common.util.concurrent.AbstractFuture
类名称:AbstractFuture
方法名:cancel
[英]Subclasses should invoke this method to mark the future as cancelled. This will set the state of the future to AbstractFuture.Sync#CANCELLED and call #done() if the state was successfully changed.
[中]子类应该调用此方法来将未来标记为已取消。这将把未来的状态设置为抽象的未来。如果状态已成功更改,则同步#取消并调用#完成()。
代码示例来源:origin: google/guava
@Override
public boolean cancel(boolean interruptIfRunning) {
InCompletionOrderState<T> localState = state;
if (super.cancel(interruptIfRunning)) {
localState.recordOutputCancellation(interruptIfRunning);
return true;
}
return false;
}
代码示例来源:origin: google/j2objc
@Override
public boolean cancel(boolean interruptIfRunning) {
InCompletionOrderState<T> localState = state;
if (super.cancel(interruptIfRunning)) {
localState.recordOutputCancellation(interruptIfRunning);
return true;
}
return false;
}
代码示例来源:origin: wildfly/wildfly
@Override
public boolean cancel(boolean interruptIfRunning) {
InCompletionOrderState<T> localState = state;
if (super.cancel(interruptIfRunning)) {
localState.recordOutputCancellation(interruptIfRunning);
return true;
}
return false;
}
代码示例来源:origin: google/guava
@CanIgnoreReturnValue
@Override
public final boolean cancel(boolean mayInterruptIfRunning) {
return super.cancel(mayInterruptIfRunning);
}
}
代码示例来源:origin: google/j2objc
@CanIgnoreReturnValue
@Override
public final boolean cancel(boolean mayInterruptIfRunning) {
return super.cancel(mayInterruptIfRunning);
}
}
代码示例来源:origin: google/guava
@Override
public Void call() {
if (currentFuture.get().cancel(true)) {
numSuccessfulSetCalls.incrementAndGet();
}
awaitUnchecked(barrier);
return null;
}
};
代码示例来源:origin: google/guava
@Override
public Void call() {
cancellationSucess.set(currentFuture.get().cancel(true));
awaitUnchecked(barrier);
return null;
}
};
代码示例来源:origin: google/guava
@Override
public void run() {
cancellationSucess.set(currentFuture.get().cancel(true));
awaitUnchecked(barrier);
}
};
代码示例来源:origin: wildfly/wildfly
@CanIgnoreReturnValue
@Override
public final boolean cancel(boolean mayInterruptIfRunning) {
return super.cancel(mayInterruptIfRunning);
}
}
代码示例来源:origin: google/guava
@Override
public void run() {
future.cancel(true);
if (!future.isDone()) {
errorMessage.set("Cancel call exited before future was complete.");
}
}
});
代码示例来源:origin: google/guava
private static void assertCannotCancel(AbstractFuture<Integer> future) {
assertThat(future.cancel(true)).isFalse();
assertThat(future.cancel(false)).isFalse();
}
}
代码示例来源:origin: google/guava
public void testGetFailure_CanceledNoCause() {
AbstractFuture<String> future = new AbstractFuture<String>() {};
future.cancel(false);
assertThat(future.tryInternalFastPathGetFailure()).isNull();
}
代码示例来源:origin: google/guava
public void testSetFutureDelegateAlreadyCancelled() throws Exception {
delegate.cancel(
false
/** mayInterruptIfRunning */
);
assertThat(future.setFuture(delegate)).isTrue();
assertCancelled(future, false);
}
代码示例来源:origin: google/guava
public void testSetFutureDelegateLaterInterrupted() throws Exception {
assertThat(future.setFuture(delegate)).isTrue();
delegate.cancel(
true
/** mayInterruptIfRunning */
);
assertCancelled(future, /* expectWasInterrupted= */ false);
}
代码示例来源:origin: google/guava
public void testSetFutureDelegateLaterCancelled() throws Exception {
assertThat(future.setFuture(delegate)).isTrue();
delegate.cancel(
false
/** mayInterruptIfRunning */
);
assertCancelled(future, false);
}
代码示例来源:origin: google/guava
public void testSetFutureDelegateAlreadyInterrupted() throws Exception {
delegate.cancel(
true
/** mayInterruptIfRunning */
);
assertThat(future.setFuture(delegate)).isTrue();
assertCancelled(future, /* expectWasInterrupted= */ false);
}
代码示例来源:origin: google/guava
public void testListenLaterSetAsynchronouslyLaterDelegateInterrupted() {
CountingRunnable before = new CountingRunnable();
CountingRunnable inBetween = new CountingRunnable();
CountingRunnable after = new CountingRunnable();
future.addListener(before, directExecutor());
future.setFuture(delegate);
future.addListener(inBetween, directExecutor());
delegate.cancel(true);
future.addListener(after, directExecutor());
before.assertRun();
inBetween.assertRun();
after.assertRun();
}
代码示例来源:origin: google/guava
public void testListenLaterSetAsynchronouslyLaterDelegateCancelled() {
CountingRunnable before = new CountingRunnable();
CountingRunnable inBetween = new CountingRunnable();
CountingRunnable after = new CountingRunnable();
future.addListener(before, directExecutor());
future.setFuture(delegate);
future.addListener(inBetween, directExecutor());
delegate.cancel(false);
future.addListener(after, directExecutor());
before.assertRun();
inBetween.assertRun();
after.assertRun();
}
代码示例来源:origin: google/guava
public void testCancel_done() throws Exception {
AbstractFuture<String> future =
new AbstractFuture<String>() {
{
set("foo");
}
};
assertFalse(future.cancel(true));
assertFalse(future.isCancelled());
assertTrue(future.isDone());
}
代码示例来源:origin: com.datastax.cassandra/cassandra-driver-core
@Override
public boolean cancel(boolean mayInterruptIfRunning) {
return (source == null || source.cancel(mayInterruptIfRunning))
&& super.cancel(mayInterruptIfRunning);
}
内容来源于网络,如有侵权,请联系作者删除!