private static final class JoinManager.ProxyRegTaskQueue extends Object implements FutureObserver
FutureObserver.ObservableFuture<T>
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.ExecutorService |
executor |
private java.util.concurrent.ConcurrentLinkedQueue<JoinManager.ProxyRegTask> |
pending |
Modifier | Constructor and Description |
---|---|
private |
ProxyRegTaskQueue(java.util.concurrent.ExecutorService e) |
Modifier and Type | Method and Description |
---|---|
void |
futureCompleted(java.util.concurrent.Future e) |
private java.util.concurrent.Future |
submit(JoinManager.ProxyRegTask t) |
private final java.util.concurrent.ConcurrentLinkedQueue<JoinManager.ProxyRegTask> pending
private final java.util.concurrent.ExecutorService executor
private ProxyRegTaskQueue(java.util.concurrent.ExecutorService e)
private java.util.concurrent.Future submit(JoinManager.ProxyRegTask t)
public void futureCompleted(java.util.concurrent.Future e)
futureCompleted
in interface FutureObserver
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.