release v2.0.6

- [opt] remove allocation via using valuetask

Author: JasonXuDeveloper

EasyEcs.Core/Context.cs

@@ -323,7 +323,7 @@ private void AddSystem(SystemBase system)
     /// <param name="action"></param>
     /// <param name="catchError"></param>
     /// <typeparam name="T"></typeparam>
-    private async Task QueryTasks<T>(List<T> list, Func<T, Task> action, bool catchError = true)
+    private async ValueTask QueryTasks<T>(List<T> list, Func<T, ValueTask> action, bool catchError = true)
     {
         if (_options.Parallel)
         {
@@ -353,7 +353,7 @@ await Parallel.ForEachAsync(list, _parallelOptions, async (item, _) =>
             // collect tasks for the current priority
             foreach (var item in list)
             {
-                _executeTasks.Add(action(item));
+                _executeTasks.Add(action(item).AsTask());
             }
 
             // dispatch all tasks of the same priority

EasyEcs.Core/Systems/ExecuteSystemWrapper.cs

@@ -16,13 +16,13 @@ internal ExecuteSystemWrapper(IExecuteSystem system)
         System = system;
     }
 
-    internal Task Update(Context context)
+    internal ValueTask Update(Context context)
     {
         if (System.ExecuteFrequency == 1 || (_counter++ > 0 && _counter % System.ExecuteFrequency == 0))
         {
             return System.OnExecute(context);
         }
 
-        return Task.CompletedTask;
+        return ValueTask.CompletedTask;
     }
 }

EasyEcs.Core/Systems/IEndSystem.cs

@@ -4,5 +4,5 @@ namespace EasyEcs.Core.Systems;
 
 public interface IEndSystem
 {
-    Task OnEnd(Context context);
+    ValueTask OnEnd(Context context);
 }

EasyEcs.Core/Systems/IExecuteSystem.cs

@@ -5,5 +5,5 @@ namespace EasyEcs.Core.Systems;
 public interface IExecuteSystem
 {
     int ExecuteFrequency => 1;
-    Task OnExecute(Context context);
+    ValueTask OnExecute(Context context);
 }

EasyEcs.Core/Systems/IInitSystem.cs

@@ -4,5 +4,5 @@ namespace EasyEcs.Core.Systems;
 
 public interface IInitSystem
 {
-    Task OnInit(Context context);
+    ValueTask OnInit(Context context);
 }

EasyEcs.UnitTest/Systems/HelloWorldSystem.cs

@@ -11,7 +11,7 @@ public class HelloWorldSystem : SystemBase, IExecuteSystem
     // Make this system to execute first
     public override int Priority => -1;
 
-    public Task OnExecute(Context context)
+    public ValueTask OnExecute(Context context)
     {
         // Get a singleton component from the context
         ref var frameComp = ref context.GetSingletonComponent<FrameComponent>().Value;
@@ -23,6 +23,6 @@ public Task OnExecute(Context context)
                           $"Time: {DateTime.Now:HH:mm:ss.fff})");
         // count frames (update singleton component data)
         frameComp.FrameCount++;
-        return Task.CompletedTask;
+        return ValueTask.CompletedTask;
     }
 }

EasyEcs.UnitTest/Systems/ModificationSystem.cs

@@ -16,7 +16,7 @@ public class ModificationSystem : SystemBase, IExecuteSystem, IEndSystem
     /// </summary>
     /// <param name="context"></param>
     /// <returns></returns>
-    public Task OnExecute(Context context)
+    public ValueTask OnExecute(Context context)
     {
         // Should be run concurrently if possible
         Console.WriteLine($"{GetType().Name} (Priority: {Priority}, " +
@@ -32,15 +32,15 @@ public Task OnExecute(Context context)
                     comp.Value.Factor = 0.5f);
         }
 
-        return Task.CompletedTask;
+        return ValueTask.CompletedTask;
     }
 
     /// <summary>
     /// Make size to 0
     /// </summary>
     /// <param name="context"></param>
     /// <returns></returns>
-    public Task OnEnd(Context context)
+    public ValueTask OnEnd(Context context)
     {
         var candidates = context.GroupOf<SizeComponent>();
 
@@ -51,6 +51,6 @@ public Task OnEnd(Context context)
             sizeComponent.Height = 0;
         }
 
-        return Task.CompletedTask;
+        return ValueTask.CompletedTask;
     }
 }

EasyEcs.UnitTest/Systems/NotUnmanagedSystem.cs

@@ -9,7 +9,7 @@ namespace EasyEcs.UnitTest.Systems;
 
 public class NotUnmanagedSystem : SystemBase, IExecuteSystem
 {
-    public Task OnExecute(Context context)
+    public ValueTask OnExecute(Context context)
     {
         var results = context.GroupOf<NotUnmanagedComponent>();
 
@@ -26,6 +26,6 @@ public Task OnExecute(Context context)
                 $" {string.Join(", ", component.Dictionary.Select(kv => $"{kv.Key}: {kv.Value}"))}");
         }
 
-        return Task.CompletedTask;
+        return ValueTask.CompletedTask;
     }
 }

EasyEcs.UnitTest/Systems/ResizeSystem.cs

@@ -8,7 +8,7 @@ namespace EasyEcs.UnitTest.Systems;
 
 public class ResizeSystem : SystemBase, IInitSystem, IExecuteSystem
 {
-    public Task OnInit(Context context)
+    public ValueTask OnInit(Context context)
     {
         // Get all entities that have ScaleComponent
         var candidates = context.GroupOf<ScaleComponent>();
@@ -21,10 +21,10 @@ public Task OnInit(Context context)
             scaleComponent.Factor = 2;
         }
 
-        return Task.CompletedTask;
+        return ValueTask.CompletedTask;
     }
 
-    public Task OnExecute(Context context)
+    public ValueTask OnExecute(Context context)
     {
         // Should be run concurrently if possible
         Console.WriteLine($"{GetType().Name} (Priority: {Priority}, " +
@@ -52,6 +52,6 @@ public Task OnExecute(Context context)
             entity.RemoveComponent<ScaleComponent>();
         }
 
-        return Task.CompletedTask;
+        return ValueTask.CompletedTask;
     }
 }

EasyEcs.UnitTest/Systems/TimeConsumingSystem.cs

@@ -7,7 +7,7 @@ namespace EasyEcs.UnitTest.Systems;
 
 public class TimeConsumingSystem : SystemBase, IExecuteSystem
 {
-    public Task OnExecute(Context context)
+    public async ValueTask OnExecute(Context context)
     {
         Console.WriteLine($"{GetType().Name} (Priority: {Priority}, " +
                           $"Thread: {Environment.CurrentManagedThreadId}, " +
@@ -17,6 +17,6 @@ public Task OnExecute(Context context)
         // other tasks at the same priority level should be able to run concurrently on other threads
         // if the system is set to run in parallel. Tasks with lower priority will be queued until
         // this task (or the most time-consuming task) is finished
-        return Task.Delay(Random.Shared.Next(10, 100));
+        await Task.Delay(Random.Shared.Next(10, 100));
     }
 }