47 lines
1.6 KiB
C#
47 lines
1.6 KiB
C#
|
namespace FileSearch.Logic.Model.Engine
|
|||
|
|
{
|
|||
|
|
internal class TimedCallback<T>
|
|||
|
|
{
|
|||
|
|
private readonly TimeSpan _timeout;
|
|||
|
|
private readonly Action<IEnumerable<T>> _callback;
|
|||
|
|
private DateTime _lastTrigger;
|
|||
|
|
private bool _isRunning = false;
|
|||
|
|
|
|||
|
|
public TimedCallback(TimeSpan timeout, Action<IEnumerable<T>> callback)
|
|||
|
|
{
|
|||
|
|
if (callback == null) throw new ArgumentNullException("callback");
|
|||
|
|
if (timeout.TotalSeconds < 0.1) throw new ArgumentException(@"The timeout should be minimal 0.1 second.", "timeout");
|
|||
|
|
|
|||
|
|
_timeout = timeout;
|
|||
|
|
_callback = callback;
|
|||
|
|
_lastTrigger = DateTime.UtcNow;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// Значение, указывающее, превышен ли период тайм-аута и можно ли получить новые данные.
|
|||
|
|
/// </summary>
|
|||
|
|
public bool DataNeeded
|
|||
|
|
{
|
|||
|
|
get { return !_isRunning && DateTime.UtcNow - _lastTrigger >= _timeout; }
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// Устанавливает данные для отправки делегату обратного вызова.
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="collection">Сбор с данными.</param>
|
|||
|
|
public void SetData(IEnumerable<T> collection)
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
_isRunning = true;
|
|||
|
|
_callback(collection);
|
|||
|
|
_lastTrigger = DateTime.UtcNow;
|
|||
|
|
}
|
|||
|
|
finally
|
|||
|
|
{
|
|||
|
|
_isRunning = false;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|