public class MemoryBasedContextService extends AbstractInjectionBasedContextService
This service is thread-safe.
Constructor and Description |
---|
MemoryBasedContextService(rootContext : Context,
injector : com.google.inject.Injector,
factory : ContextFactory)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
ConcurrentLinkedDeque<Context> |
getAllContexts()
Replies all the contexts.
|
protected ConcurrentHashMap<UUID,Context> |
getContextInternalStructure()
Replies the internal data structure for storing the contexts.
|
newContextInstance
createContext, createContextWithoutRegistration, getContext, getRootContext, onStart, onStop, removeContext
doStart, doStop
addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, doCancelStart, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString
@Inject
public new
(rootContext : Context,
injector : com.google.inject.Injector,
factory : ContextFactory)
rootContext
- the root context.injector
- is the injector.factory
- is the factory of contexts.lock
- is the lock that must be used by this service.protected def
getContextInternalStructure() : ConcurrentHashMap<UUID,Context>
AbstractContextService
This function is not thread-safe.
getContextInternalStructure
in class AbstractContextService
public def
getAllContexts() : ConcurrentLinkedDeque<Context>
ContextService
Copyright © 2020 the original authors or authors.