Package com.storedobject.core

Class DataCollector<D>

java.lang.Object

com.storedobject.core.DataCollector<D>

Type Parameters:

D - The type of data being managed by the DataCollector.

All Implemented Interfaces:

Closeable, AutoCloseable

public class DataCollector<D>
extends Object
implements Closeable

A utility class responsible for periodically collecting and analyzing data, and notifying a DataDistributor of changes or activity.

The DataCollector runs a scheduled task that executes at a fixed interval. This task evaluates whether the data has changed using a provided Predicate. If a change is detected, the dataUpdated method of the DataDistributor is invoked. Otherwise, the pingReceived method of the DataDistributor is called to indicate that the periodic check occurred.

The frequency of data collection can be configured through the constructor. If the frequency is less than or equal to zero, a default interval of 5 seconds is used.

Author:

Syam

Constructor Summary

Constructors

Constructor	Description
DataCollector(Predicate<D> collector, DataDistributor<D> distributor, int collectionFrequency)	Constructs a new DataCollector instance that periodically evaluates data changes and notifies the DataDistributor of updates or activity.

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the DataCollector and shuts down the associated scheduled task execution.

Methods inherited from class java.lang.Object

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

Constructor Details

DataCollector

public DataCollector(Predicate<D> collector,
 DataDistributor<D> distributor,
 int collectionFrequency)

Constructs a new DataCollector instance that periodically evaluates data changes and notifies the DataDistributor of updates or activity.

Parameters:

collector - a Predicate used to determine if the data has changed. The predicate should return true if the data is updated, or false otherwise.

distributor - the DataDistributor which provides the data to be evaluated and handles notifications for updates or periodic activity.

collectionFrequency - the frequency, in seconds, at which the data collection and evaluation task should run. If the value is less than or equal to zero, a default interval of 5 seconds is used.

Method Details

close

public void close()

Closes the DataCollector and shuts down the associated scheduled task execution.

This method initiates a graceful shutdown of the scheduler, allowing any currently executing tasks to complete within a timeout period of 5 seconds. If tasks do not terminate within this timeframe, the scheduler is forcibly shut down. Interruptions during this process are handled appropriately, and the thread's interrupt status is restored.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable