|
|
|
|
using System;
|
|
|
|
|
using ZeroLevel.Services.Shedulling;
|
|
|
|
|
|
|
|
|
|
namespace ZeroLevel
|
|
|
|
|
{
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// The default scheduler is intended for service tasks
|
|
|
|
|
/// </summary>
|
|
|
|
|
public static class Sheduller
|
|
|
|
|
{
|
|
|
|
|
#region Factory
|
|
|
|
|
|
|
|
|
|
public static IExpirationSheduller CreateExpirationSheduller()
|
|
|
|
|
{
|
|
|
|
|
return new DateTimeSheduller();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static ISheduller Create()
|
|
|
|
|
{
|
|
|
|
|
return new ShedullerImpl();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#endregion Factory
|
|
|
|
|
|
|
|
|
|
#region Singletones
|
|
|
|
|
|
|
|
|
|
private static ISheduller __instanse;
|
|
|
|
|
private static readonly object _create_lock = new object();
|
|
|
|
|
|
|
|
|
|
private static ISheduller DefaultInstance
|
|
|
|
|
{
|
|
|
|
|
get
|
|
|
|
|
{
|
|
|
|
|
if (__instanse == null!)
|
|
|
|
|
{
|
|
|
|
|
lock (_create_lock)
|
|
|
|
|
{
|
|
|
|
|
if (__instanse == null!)
|
|
|
|
|
{
|
|
|
|
|
__instanse = Sheduller.Create();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return __instanse;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static DateTime GetExpirationDate(long index)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance[index];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#endregion Singletones
|
|
|
|
|
|
|
|
|
|
#region Sync default instance api
|
|
|
|
|
|
|
|
|
|
public static long RemindWhile(TimeSpan timespan, Func<long, bool> callback, Action continueWith = null!)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindWhile(timespan, callback, continueWith);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static long RemindWhile(TimeSpan timespan, Func<bool> callback, Action continueWith = null!)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindWhile(timespan, _ => callback(), continueWith);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static long RemindAfter(TimeSpan timespan, Action<long> callback)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindAfter(timespan, callback);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static long RemindAfter(TimeSpan timespan, Action callback)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindAfter(timespan, _ => callback());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static long RemindAt(DateTime date, Action<long> callback)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindAt(date, callback);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static long RemindAt(DateTime date, Action callback)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindAt(date, _ => callback());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static long RemindEvery(TimeSpan first, TimeSpan next, Action<long> callback)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindEvery(first, next, callback);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static long RemindEvery(TimeSpan first, TimeSpan next, Action callback)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindEvery(first, next, _ => callback());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static long RemindEvery(TimeSpan timespan, Action<long> callback)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindEvery(timespan, callback);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static long RemindEvery(TimeSpan timespan, Action callback)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindEvery(timespan, _ => callback());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// Performs an action once a period, while the period is recalculated according to the transferred function at each re-creation of the task.
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="nextEventPeriodCalcFunction">Function to calculate the next period</param>
|
|
|
|
|
/// <param name="callback">Action</param>
|
|
|
|
|
/// <returns>Task ID</returns>
|
|
|
|
|
public static long RemindEveryNonlinearPeriod(Func<TimeSpan> nextEventPeriodCalcFunction, Action<long> callback)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindEveryNonlinearPeriod(nextEventPeriodCalcFunction, nextEventPeriodCalcFunction, callback);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static long RemindEveryNonlinearPeriod(Func<TimeSpan> nextEventPeriodCalcFunction, Action callback)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindEveryNonlinearPeriod(nextEventPeriodCalcFunction, nextEventPeriodCalcFunction, k => callback());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// Performs an action once a period, while the period is recalculated according to the transferred function at each re-creation of the task.
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="firstEventPeriodCalcFunction">The function to calculate the period to the first execution</param>
|
|
|
|
|
/// <param name="nextEventPeriodCalcFunction">The function for calculating the period until subsequent performances</param>
|
|
|
|
|
/// <param name="callback">Action</param>
|
|
|
|
|
/// <returns>Task ID</returns>
|
|
|
|
|
public static long RemindEveryNonlinearPeriod(Func<TimeSpan> firstEventPeriodCalcFunction, Func<TimeSpan> nextEventPeriodCalcFunction, Action<long> callback)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindEveryNonlinearPeriod(firstEventPeriodCalcFunction, nextEventPeriodCalcFunction, callback);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static long RemindEveryNonlinearPeriod(Func<TimeSpan> firstEventPeriodCalcFunction, Func<TimeSpan> nextEventPeriodCalcFunction, Action callback)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindEveryNonlinearPeriod(firstEventPeriodCalcFunction, nextEventPeriodCalcFunction, k => callback());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// Performs an action once per period, while the date is recalculated from the function transferred each time the task is recreated.
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="nextEventDateCalcFunction">The function to calculate the next date</param>
|
|
|
|
|
/// <param name="callback">Action</param>
|
|
|
|
|
/// <returns>Task ID</returns>
|
|
|
|
|
public static long RemindEveryNonlinearDate(Func<DateTime, DateTime> nextEventDateCalcFunction, Action<long> callback)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindEveryNonlinearDate(nextEventDateCalcFunction, nextEventDateCalcFunction, callback);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static long RemindEveryNonlinearDate(Func<DateTime, DateTime> nextEventDateCalcFunction, Action callback)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindEveryNonlinearDate(nextEventDateCalcFunction, nextEventDateCalcFunction, k => callback());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// Performs an action once per period, while the date is recalculated from the function transferred each time the task is recreated.
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="firstEventDateCalcFunction">The function to calculate the first run date</param>
|
|
|
|
|
/// <param name="nextEventDateCalcFunction">The function to calculate the next date</param>
|
|
|
|
|
/// <param name="callback">Action</param>
|
|
|
|
|
/// <returns>Task ID</returns>
|
|
|
|
|
public static long RemindEveryNonlinearDate(Func<DateTime, DateTime> firstEventDateCalcFunction,
|
|
|
|
|
Func<DateTime, DateTime> nextEventDateCalcFunction, Action<long> callback)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindEveryNonlinearDate(firstEventDateCalcFunction, nextEventDateCalcFunction, callback);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static long RemindEveryNonlinearDate(Func<DateTime, DateTime> firstEventDateCalcFunction,
|
|
|
|
|
Func<DateTime, DateTime> nextEventDateCalcFunction, Action callback)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.RemindEveryNonlinearDate(firstEventDateCalcFunction, nextEventDateCalcFunction, k => callback());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static bool Remove(long key)
|
|
|
|
|
{
|
|
|
|
|
return DefaultInstance.Remove(key);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#endregion Sync default instance api
|
|
|
|
|
|
|
|
|
|
#region Default instances control
|
|
|
|
|
|
|
|
|
|
public static void Pause()
|
|
|
|
|
{
|
|
|
|
|
DefaultInstance.Pause();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static void Resume()
|
|
|
|
|
{
|
|
|
|
|
DefaultInstance.Resume();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static void Clean()
|
|
|
|
|
{
|
|
|
|
|
DefaultInstance.Clean();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static void Dispose()
|
|
|
|
|
{
|
|
|
|
|
DefaultInstance.Dispose();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#endregion Default instances control
|
|
|
|
|
}
|
|
|
|
|
}
|