ServiceDiscoveryManager.CacheTaskDependencyManager (Apache River v3.0.0 API Documentation (internals))

private static final class ServiceDiscoveryManager.CacheTaskDependencyManager
extends Object
implements FutureObserver

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.river.thread.FutureObserver
  FutureObserver.ObservableFuture<T>

Fields
Modifier and Type	Field and Description
`private java.util.concurrent.ExecutorService`	`executor`
`private java.util.concurrent.ConcurrentLinkedQueue<ServiceDiscoveryManager.CacheTaskWrapper>`	`pending`

Constructors
Modifier	Constructor and Description
`private`	`CacheTaskDependencyManager(java.util.concurrent.ExecutorService e)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`futureCompleted(java.util.concurrent.Future e)`
`private void`	`removeUselessTask(ServiceDiscoveryManager.ProxyReg reg)` Removes from the cache's task queue, all pending tasks associated with the given ProxyReg.
`private ServiceDiscoveryManager.CacheTaskWrapper`	`submit(Runnable t)`

private final java.util.concurrent.ConcurrentLinkedQueue<ServiceDiscoveryManager.CacheTaskWrapper> pending

private final java.util.concurrent.ExecutorService executor

private CacheTaskDependencyManager(java.util.concurrent.ExecutorService e)

Class ServiceDiscoveryManager.CacheTaskDependencyManager