io.sarl.sre.janus.services.probing.service
Class AsynchronousProbeService
All Superinterfaces:
IProbeReleaseListener, ProbeService, java.util.EventListener, org.arakhne.afc.services.IService
class AsynchronousProbeService
extends AbstractProbeService
This class is the implementation of a probe service that is updating the values asynchronously. Asynchronous updates means that the sync() function is invoking by a specific thread.
Maven Group Identifier:
io.sarl.sre.janus
Maven Artifact Identifier:
janus.kernel
Since:
0.10
See:
SynchronousProbeService
Property Summary
Modifier and type Property and description
long sleepingDurationBetweenSyncs
Inherited: probes, referenceType
Constructor Summary
Constructor and description
new(ExecutorService,NamespaceService,INameParser,Provider<T>)
Constructor.
Action Summary
Modifier and type Action and description
protected java.lang.Runnable createRunnableUpdater
Invoked to create a Runnable that may be used for updated the probes
long getSleepingDurationBetweenSyncs
boolean isAsynchronousSynchronizationRunning
Replies if the asynchronous synchronization was started or not.
protected void onFirstProbe
protected void onLastProbe
void onStop
void setSleepingDurationBetweenSyncs(long)
java.util.concurrent.Future<V> startSyncThread
Start the thread that dynamically update the probes
void stopSyncThread
Stop the thread that dynamically update the probes
Inherited: getProbes, getReferenceType, internalSync, newProbe(Object,Class<T>,URI,String), onProbeReleasedProbe(Probe<T>), probe(SarlName,Class<T>,[String]), probe(String,Class<T>,[String]), probe(URI,Class<T>,[String]), releaseAllProbes, sync
Property Details
sleepingDurationBetweenSyncs 
var sleepingDurationBetweenSyncs : long

This property is an alias for the action: getSleepingDurationBetweenSyncs

Constructor Details
new(ExecutorService,NamespaceService,INameParser,Provider<T>) 
new(ExecutorService,NamespaceService,INameParser,Provider<T>)
Constructor.
Parameters:
service - the executor service.
namespaceService - the service that is giving access to the namespaces.
nameParser - the object that is able to parse resource names.
factories - the provider of factories tool.
Action Details
createRunnableUpdater 
protected def createRunnableUpdater : java.lang.Runnable
Invoked to create a Runnable that may be used for updated the probes
Returns:
the Runnable insstance, never null .
getSleepingDurationBetweenSyncs 
def getSleepingDurationBetweenSyncs : long
isAsynchronousSynchronizationRunning 
def isAsynchronousSynchronizationRunning : boolean
Replies if the asynchronous synchronization was started or not.
Returns:
true if the synchronization was started into a thread.
Since:
0.12
onFirstProbe 
protected def onFirstProbe
onLastProbe 
protected def onLastProbe
onStop 
def onStop
setSleepingDurationBetweenSyncs(long) 
def setSleepingDurationBetweenSyncs(long)
startSyncThread 
def startSyncThread : java.util.concurrent.Future<V>
Start the thread that dynamically update the probes
stopSyncThread 
def stopSyncThread
Stop the thread that dynamically update the probes