Add ability to specify scheduler implementation in configuration

src/core/Akka.Tests/Actor/ActorSystemSpec.cs

@@ -89,6 +89,19 @@ public void AnActorSystem_Must_Support_Dynamically_Registered_Extensions()
             Assert.Equal(Sys, otherTestExtension.System);
         }
 
+        [Fact]
+        public void AnActorSystem_Must_Setup_The_Default_Scheduler()
+        {
+            Assert.True(Sys.Scheduler.GetType() == typeof(DedicatedThreadScheduler));
+        }
+
+        [Fact]
+        public void AnActorSystem_Must_Support_Using_A_Customer_Scheduler()
+        {
+            var actorSystem = ActorSystem.Create(Guid.NewGuid().ToString(), DefaultConfig.WithFallback("akka.scheduler.implementation = \"Akka.Tests.Actor.TestScheduler, Akka.Tests\""));
+            Assert.True(actorSystem.Scheduler.GetType() == typeof(TestScheduler));
+        }
+
         #endregion
     }
 
@@ -127,5 +140,40 @@ public TestExtensionImpl(ActorSystem system)
 
         public ActorSystem System { get; private set; }
     }
+
+    public class TestScheduler : IScheduler
+    {
+        public TestScheduler(ActorSystem system)
+        {
+
+        }
+
+        public void ScheduleTellOnce(TimeSpan delay, ICanTell receiver, object message, IActorRef sender)
+        {
+            throw new NotImplementedException();
+        }
+
+        public void ScheduleTellOnce(TimeSpan delay, ICanTell receiver, object message, IActorRef sender, ICancelable cancelable)
+        {
+            throw new NotImplementedException();
+        }
+
+        public void ScheduleTellRepeatedly(TimeSpan initialDelay, TimeSpan interval, ICanTell receiver, object message,
+            IActorRef sender)
+        {
+            throw new NotImplementedException();
+        }
+
+        public void ScheduleTellRepeatedly(TimeSpan initialDelay, TimeSpan interval, ICanTell receiver, object message,
+            IActorRef sender, ICancelable cancelable)
+        {
+            throw new NotImplementedException();
+        }
+
+        public DateTimeOffset Now { get; private set; }
+        public TimeSpan MonotonicClock { get; private set; }
+        public TimeSpan HighResMonotonicClock { get; private set; }
+        public IAdvancedScheduler Advanced { get; private set; }
+    }
 }
 

src/core/Akka/Actor/Internals/ActorSystemImpl.cs

@@ -53,9 +53,9 @@ public ActorSystemImpl(string name, Config config)
 
             _name = name;            
             ConfigureSettings(config);
+            ConfigureScheduler();
             ConfigureEventStream();
             ConfigureProvider();
-            ConfigureScheduler();
             ConfigureSerialization();
             ConfigureMailboxes();
             ConfigureDispatchers();
@@ -127,7 +127,8 @@ public override ActorSelection ActorSelection(string actorPath)
 
         private void ConfigureScheduler()
         {
-            _scheduler = new DedicatedThreadScheduler(this);;// new TaskBasedScheduler();
+            var schedulerType = Type.GetType(_settings.SchedulerClass, true);
+            _scheduler = (IScheduler) Activator.CreateInstance(schedulerType, this);
         }
 
         /// <summary>

src/core/Akka/Actor/Scheduler/SchedulerBase.cs

@@ -21,7 +21,6 @@ void ITellScheduler.ScheduleTellOnce(TimeSpan delay, ICanTell receiver, object m
         {
             ValidateDelay(delay, "delay");
             InternalScheduleTellOnce(delay, receiver, message, sender, cancelable);
-
         }
 
         void ITellScheduler.ScheduleTellRepeatedly(TimeSpan initialDelay, TimeSpan interval, ICanTell receiver, object message, IActorRef sender)
@@ -38,7 +37,6 @@ void ITellScheduler.ScheduleTellRepeatedly(TimeSpan initialDelay, TimeSpan inter
             InternalScheduleTellRepeatedly(initialDelay, interval, receiver, message, sender, cancelable);
         }
 
-
         void IActionScheduler.ScheduleOnce(TimeSpan delay, Action action)
         {
             ValidateDelay(delay, "delay");
@@ -66,22 +64,18 @@ void IActionScheduler.ScheduleRepeatedly(TimeSpan initialDelay, TimeSpan interva
         }
 
         IAdvancedScheduler IScheduler.Advanced { get { return this; } }
-
         DateTimeOffset ITimeProvider.Now { get { return TimeNow; } }
-
-
+
         protected abstract DateTimeOffset TimeNow { get; }
         public abstract TimeSpan MonotonicClock { get; }
         public abstract TimeSpan HighResMonotonicClock { get; }
 
         protected abstract void InternalScheduleTellOnce(TimeSpan delay, ICanTell receiver, object message, IActorRef sender, ICancelable cancelable);
-
         protected abstract void InternalScheduleTellRepeatedly(TimeSpan initialDelay, TimeSpan interval, ICanTell receiver, object message, IActorRef sender, ICancelable cancelable);
 
         protected abstract void InternalScheduleOnce(TimeSpan delay, Action action, ICancelable cancelable);
         protected abstract void InternalScheduleRepeatedly(TimeSpan initialDelay, TimeSpan interval, Action action, ICancelable cancelable);
 
-
         protected static void ValidateInterval(TimeSpan interval, string parameterName)
         {
             if(interval <= TimeSpan.Zero)

src/core/Akka/Actor/Settings.cs

@@ -107,6 +107,8 @@ public Settings(ActorSystem system, Config config)
             DebugRouterMisconfiguration = Config.GetBoolean("akka.actor.debug.router-misconfiguration");
             Home = Config.GetString("akka.home") ?? "";
             DefaultVirtualNodesFactor = Config.GetInt("akka.actor.deployment.default.virtual-nodes-factor");
+
+            SchedulerClass = Config.GetString("akka.scheduler.implementation");
             //TODO: dunno.. we dont have FiniteStateMachines, dont know what the rest is
             /*              
                 final val SchedulerClass: String = getString("akka.scheduler.implementation")
@@ -260,6 +262,11 @@ public Settings(ActorSystem system, Config config)
         /// </summary>
         public int DefaultVirtualNodesFactor { get; private set; }
 
+        /// <summary>
+        /// Gets the scheduler implementation used by this system.
+        /// </summary>
+        public string SchedulerClass { get; private set; }
+
         /// <summary>
         ///     Returns a <see cref="string" /> that represents this instance.
         /// </summary>

src/core/Akka/Configuration/Pigeon.conf

@@ -435,7 +435,7 @@ akka {
     #  1) com.typesafe.config.Config
     #  2) akka.event.LoggingAdapter
     #  3) java.util.concurrent.ThreadFactory
-    implementation = akka.actor.LightArrayRevolverScheduler
+    implementation = "Akka.Actor.DedicatedThreadScheduler"
 
     # When shutting down the scheduler, there will typically be a thread which
     # needs to be stopped, and this timeout determines how long to wait for