本文整理了Java中com.google.common.util.concurrent.AbstractFuture.addListener()
方法的一些代码示例,展示了AbstractFuture.addListener()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。AbstractFuture.addListener()
方法的具体详情如下:
包路径:com.google.common.util.concurrent.AbstractFuture
类名称:AbstractFuture
方法名:addListener
暂无
代码示例来源:origin: google/guava
@Override
public final void addListener(Runnable listener, Executor executor) {
super.addListener(listener, executor);
}
代码示例来源:origin: google/j2objc
@Override
public final void addListener(Runnable listener, Executor executor) {
super.addListener(listener, executor);
}
代码示例来源:origin: wildfly/wildfly
@Override
public final void addListener(Runnable listener, Executor executor) {
super.addListener(listener, executor);
}
代码示例来源:origin: google/guava
@Override
public void run() {
currentFuture.get().addListener(listener, executor);
}
});
代码示例来源:origin: google/guava
@Override
public Void call() throws Exception {
currentFuture.get().addListener(listener, executor);
return null;
}
});
代码示例来源:origin: google/guava
f.get();
final AtomicBoolean ranImmediately = new AtomicBoolean();
f.addListener(
new Runnable() {
@Override
代码示例来源:origin: google/guava
private static void assertDone(AbstractFuture<Integer> future) {
CountingRunnable listener = new CountingRunnable();
future.addListener(listener, directExecutor());
listener.assertRun();
assertThat(future.isDone()).isTrue();
assertCannotSet(future);
assertCannotCancel(future);
}
代码示例来源:origin: google/guava
private static void assertPending(AbstractFuture<Integer> future) {
assertThat(future.isDone()).isFalse();
assertThat(future.isCancelled()).isFalse();
CountingRunnable listener = new CountingRunnable();
future.addListener(listener, directExecutor());
listener.assertNotRun();
verifyGetOnPendingFuture(future);
verifyTimedGetOnPendingFuture(future);
}
代码示例来源:origin: org.apache.twill/twill-zookeeper
@Override
public void addListener(final Runnable listener, final Executor exec) {
super.addListener(new Runnable() {
@Override
public void run() {
exec.execute(listener);
}
}, executor);
}
代码示例来源:origin: com.diffplug.guava/guava-concurrent
@Override
public final void addListener(Runnable listener, Executor executor) {
super.addListener(listener, executor);
}
}
代码示例来源:origin: org.jboss.eap/wildfly-client-all
@Override
public final void addListener(Runnable listener, Executor executor) {
super.addListener(listener, executor);
}
代码示例来源:origin: com.alibaba.edas/edas-sdk
@Override
public void addListener(final Runnable listener) {
super.addListener(listener, executor);
}
代码示例来源:origin: org.kill-bill.billing/killbill-platform-osgi-bundles-logger
@Override
public final void addListener(Runnable listener, Executor executor) {
super.addListener(listener, executor);
}
代码示例来源:origin: apache/twill
@Override
public void addListener(final Runnable listener, final Executor exec) {
super.addListener(new Runnable() {
@Override
public void run() {
exec.execute(listener);
}
}, executor);
}
代码示例来源:origin: org.apache.qpid/qpid-bdbstore
@Override
public void addListener(final Runnable listener, final Executor exec)
{
super.addListener(listener, exec);
_commitThread.explicitNotify();
}
}
代码示例来源:origin: com.google.guava/guava-tests
@Override public Void call() throws Exception {
currentFuture.get().addListener(listener, executor);
return null;
}
});
代码示例来源:origin: io.airlift.drift/drift-transport-netty
private InvocationResponseFuture(InvokeRequest request, ConnectionParameters connectionParameters, ConnectionManager connectionManager)
{
this.request = requireNonNull(request, "request is null");
this.connectionParameters = requireNonNull(connectionParameters, "connectionConfig is null");
this.connectionManager = requireNonNull(connectionManager, "connectionManager is null");
// if this invocation is canceled, cancel the tasks
super.addListener(() -> {
if (super.isCancelled()) {
onCancel(wasInterrupted());
}
}, directExecutor());
}
代码示例来源:origin: airlift/drift
private InvocationResponseFuture(InvokeRequest request, ConnectionParameters connectionParameters, ConnectionManager connectionManager)
{
this.request = requireNonNull(request, "request is null");
this.connectionParameters = requireNonNull(connectionParameters, "connectionConfig is null");
this.connectionManager = requireNonNull(connectionManager, "connectionManager is null");
// if this invocation is canceled, cancel the tasks
super.addListener(() -> {
if (super.isCancelled()) {
onCancel(wasInterrupted());
}
}, directExecutor());
}
代码示例来源:origin: com.google.guava/guava-tests
private static void assertDone(AbstractFuture<Integer> future) {
CountingRunnable listener = new CountingRunnable();
future.addListener(listener, directExecutor());
listener.assertRun();
assertThat(future.isDone()).isTrue();
assertCannotSet(future);
assertCannotCancel(future);
}
代码示例来源:origin: com.google.guava/guava-tests
private static void assertPending(AbstractFuture<Integer> future) {
assertThat(future.isDone()).isFalse();
assertThat(future.isCancelled()).isFalse();
CountingRunnable listener = new CountingRunnable();
future.addListener(listener, directExecutor());
listener.assertNotRun();
verifyGetOnPendingFuture(future);
verifyTimedGetOnPendingFuture(future);
}
内容来源于网络,如有侵权,请联系作者删除!