ConcurrentTeskProgress

Author: sergey-shandar

src/ResourceManager/Common/Commands.Common.Strategies.UnitTest/TimeSlotTest.cs

@@ -20,6 +20,8 @@ public void AddTest()
             Assert.AreEqual(1, first.TaskCount);
             Assert.AreEqual(next, first.Next);
 
+            Assert.AreEqual(10.0, first.GetTaskProgress(10));
+
             Assert.AreEqual(0, next.Duration);
             Assert.AreEqual(0, next.TaskCount);
             Assert.AreEqual(null, next.Next);
@@ -31,6 +33,8 @@ public void AddTest()
             Assert.AreEqual(next2, first.Next);
             Assert.AreEqual(next, first.Next);
 
+            Assert.AreEqual(20.0, first.GetTaskProgress(40));
+
             Assert.AreEqual(0, next2.Duration);
             Assert.AreEqual(0, next2.TaskCount);
             Assert.AreEqual(null, next2.Next);
@@ -40,11 +44,15 @@ public void AddTest()
             Assert.AreEqual(3, first.TaskCount);
             Assert.AreEqual(next3, first.Next);
 
+            Assert.AreEqual(3.0, first.GetTaskProgress(9));
+
             Assert.AreEqual(20, next3.Duration);
             Assert.AreEqual(2, next3.TaskCount);
             Assert.AreEqual(next2, next3.Next);
             Assert.AreEqual(next, next3.Next);
 
+            Assert.AreEqual(10.0 + 5, first.GetTaskProgress(40));
+
             Assert.AreEqual(0, next2.Duration);
             Assert.AreEqual(0, next2.TaskCount);
             Assert.AreEqual(null, next2.Next);
@@ -54,6 +62,8 @@ public void AddTest()
             Assert.AreEqual(1, next2.TaskCount);
             Assert.AreEqual(next4, next2.Next);
 
+            Assert.AreEqual((30.0 / 4) + (20.0 / 3) + 20, first.GetTaskProgress(70));
+
             Assert.AreEqual(0, next4.Duration);
             Assert.AreEqual(0, next4.TaskCount);
             Assert.AreEqual(null, next4.Next);

src/ResourceManager/Common/Commands.Common.Strategies/Commands.Common.Strategies.csproj

@@ -73,6 +73,7 @@
     <Compile Include="IResourceConfig.cs" />
     <Compile Include="IResourceConfigVisitor.cs" />
     <Compile Include="IShouldProcess.cs" />
+    <Compile Include="ConcurrentTaskProgress.cs" />
     <Compile Include="TimeSlot.cs" />
     <Compile Include="StateOperationContext.cs" />
     <Compile Include="Compute\ComputeStrategy.cs" />

src/ResourceManager/Common/Commands.Common.Strategies/ConcurrentTaskProgress.cs

@@ -0,0 +1,18 @@
+namespace Microsoft.Azure.Commands.Common.Strategies
+{
+    public sealed class ConcurrentTaskProgress
+    {
+        public TimeSlot TimeSlot { get; }
+
+        public int Begin { get; }
+
+        public ConcurrentTaskProgress(TimeSlot timeSlot, int begin)
+        {
+            TimeSlot = timeSlot;
+            Begin = begin;
+        }
+
+        public ConcurrentTaskProgress AddTask(int duration)
+            => new ConcurrentTaskProgress(TimeSlot.AddTask(duration), Begin + duration);
+    }
+}

src/ResourceManager/Common/Commands.Common.Strategies/TimeSlot.cs

@@ -1,5 +1,12 @@
 namespace Microsoft.Azure.Commands.Common.Strategies
 {
+    /// <summary>
+    /// TimeSlot is a node of a singly linked list of TimeSlots.
+    /// The last node of the list is always an empty time slot
+    /// - Duration = 0.
+    /// - Next = null.
+    /// - TaskCount = 0.
+    /// </summary>
     public sealed class TimeSlot
     {
         public int Duration { get; private set; }
@@ -10,9 +17,7 @@ public sealed class TimeSlot
 
         public bool IsLast => Next == null;
 
-        public TimeSlot() : this(0, 0, null)
-        {            
-        }
+        public TimeSlot() : this(0, 0, null) { }
 
         TimeSlot(int duration, int taskCount, TimeSlot next)
         {
@@ -47,5 +52,13 @@ public TimeSlot AddTask(int duration)
                 return Next.AddTask(duration - Duration);
             }
         }
+
+        public double GetTaskProgress(int duration)
+            => duration <= Duration 
+                ? GetProgress(duration)
+                : GetProgress(Duration) + Next.GetTaskProgress(duration - Duration);
+
+        double GetProgress(double duration)
+            => duration / TaskCount;
     }
 }

src/ResourceManager/Common/Commands.Common.Strategies/TimeSlotExtensions.cs

@@ -2,6 +2,6 @@
 {
     class TimeSlotExtensions
     {
-        public TimeSlot
+        // public TimeSlot
     }
 }