Async cron

chrisa23 · Nov 17, 2019 · f1ff916 · f1ff916
1 parent cb2a10a
commit f1ff916
Show file tree

Hide file tree

Showing 6 changed files with 35 additions and 3 deletions.
diff --git a/Fibrous.WPF/Fibrous.WPF.3.0.1-beta.nupkg b/Fibrous.WPF/Fibrous.WPF.3.0.1-beta.nupkg
diff --git a/Fibrous.WPF/package.nuspec b/Fibrous.WPF/package.nuspec
@@ -3,7 +3,7 @@
 <package xmlns="http://schemas.microsoft.com/packaging/2013/05/nuspec.xsd">
   <metadata>
     <id>Fibrous.WPF</id>
-    <version>3.0.0-beta</version>
+    <version>3.0.1-beta</version>
     <authors>Chris Anderson</authors>
     <owners>chrisa23</owners>
     <projectUrl>http://github.com/chrisa23/fibrous</projectUrl>
@@ -12,7 +12,7 @@
     <copyright>Copyright ©2018 CA Anderson LLC</copyright>
     <tags>concurrency actors multi-threading messaging WPF</tags>
     <dependencies>
-      <dependency id="Fibrous" version="3.0.0-beta" />
+      <dependency id="Fibrous" version="3.0.1-beta" />
     </dependencies>
   </metadata>
   <files>

diff --git a/Fibrous/Fibrous.3.0.1-beta.nupkg b/Fibrous/Fibrous.3.0.1-beta.nupkg
diff --git a/Fibrous/IAsyncFiber.cs b/Fibrous/IAsyncFiber.cs
@@ -49,7 +49,39 @@ public interface IAsyncExecutor
     {
         Task Execute(Func<Task> toExecute);
     }
+    public static class AsyncSchedulerExtensions
+    {
+        /// <summary>
+        ///     Schedule an action at a DateTime
+        /// </summary>
+        /// <param name="scheduler"></param>
+        /// <param name="action"></param>
+        /// <param name="when"></param>
+        /// <returns></returns>
+        public static IDisposable Schedule(this IAsyncScheduler scheduler, Func<Task> action, DateTime when)
+        {
+            return scheduler.Schedule(action, when - DateTime.Now);
+        }
+
+        /// <summary>
+        ///     Schedule an action at a DateTime with an interval
+        /// </summary>
+        /// <param name="scheduler"></param>
+        /// <param name="action"></param>
+        /// <param name="when"></param>
+        /// <param name="interval"></param>
+        /// <returns></returns>
+        public static IDisposable Schedule(this IAsyncScheduler scheduler, Func<Task> action, DateTime when, TimeSpan interval)
+        {
+            return scheduler.Schedule(action, when - DateTime.Now, interval);
+        }
+
 
+        public static IDisposable CronSchedule(this IAsyncScheduler scheduler, Func<Task> action, string cron)
+        {
+            return new AsyncCronScheduler(scheduler, action, cron);
+        }
+    }
     public static class AsyncFiberExtensions
     {
         /// <summary>

diff --git a/Fibrous/IFiber.cs b/Fibrous/IFiber.cs
@@ -1,5 +1,6 @@
 using System;
 using System.Collections.Generic;
+using System.Threading.Tasks;
 
 namespace Fibrous
 {

diff --git a/Todo.txt b/Todo.txt
@@ -2,5 +2,4 @@
 - better Req/reply tests
 - add multi producer tests
 - add queue full tests
-- add cron scheduling
 - clean up ctors to allow injection of schedulers