io.sarl.sre.services.probing

Class SynchronousProbeService

java.lang.Object

com.google.common.util.concurrent.AbstractService

io.sarl.sre.services.AbstractSreService

io.sarl.sre.services.probing.AbstractProbeService

io.sarl.sre.services.probing.SynchronousProbeService

All Implemented Interfaces:

com.google.common.util.concurrent.Service, IProbeReleaseListener, ProbeService, EventListener

public class SynchronousProbeService
extends AbstractProbeService

This class is the implementation of a probe service that is updating the values synchronously. Synchronous updates must be explicitly started by invoking AbstractProbeService.sync().

Since:

0.10

Version:

0.12.0-SNAPSHOT 2020-06-30 17:45:08

Author:

Stéphane Galland

See Also:

AsynchronousProbeService

Maven Group Id:

io.janusproject

Maven Artifact Id:

io.janusproject.plugin

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Constructor and Description
SynchronousProbeService(internalStructure : Map<URI,Probe<?>>, namespaceService : NamespaceService, nameParser : NameParser, listenerCollectionProvider : javax.inject.Provider<SmartListenerCollection<?>>) Constructor.
SynchronousProbeService(namespaceService : NamespaceService, nameParser : NameParser, listenerCollectionProvider : javax.inject.Provider<SmartListenerCollection<?>>) Constructor.

Method Summary

Methods inherited from class io.sarl.sre.services.probing.AbstractProbeService

getProbes, newProbe, onFirstProbe, onLastProbe, onProbeReleasedProbe, onStop, probe, probe, probe, releaseAllProbes, sync

Methods inherited from class io.sarl.sre.services.AbstractSreService

doStart, doStop, onStart

Methods inherited from class com.google.common.util.concurrent.AbstractService

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, doCancelStart, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.common.util.concurrent.Service

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, startAsync, state, stopAsync

Constructor Detail

SynchronousProbeService

@Inject
public new(namespaceService : NamespaceService,
                   nameParser : NameParser,
                   listenerCollectionProvider : javax.inject.Provider<SmartListenerCollection<?>>)

Constructor.

Parameters:

namespaceService - the service that is giving access to the namespaces.

nameParser - the object that is able to parse resource names.

listenerCollectionProvider - the provider of listener collections.

lockProvider - the provider of synchronization locks.

SynchronousProbeService

public new(internalStructure : Map<URI,Probe<?>>,
           namespaceService : NamespaceService,
           nameParser : NameParser,
           listenerCollectionProvider : javax.inject.Provider<SmartListenerCollection<?>>)

Constructor.

Parameters:

internalStructure - is the internal structure for storing the probes.

namespaceService - the service that is giving access to the namespaces.

nameParser - the object that is able to parse resource names.

listenerCollectionProvider - the provider of listener collections.

lockProvider - the provider of synchronization locks.