init

Author: SpringHgui

.gitignore

@@ -0,0 +1,3 @@
+.vs
+obj
+bin

HashedWheelTimer/Concurrency/IRunnable.cs

@@ -0,0 +1,10 @@
+// Copyright (c) Microsoft. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+namespace WheelTimer.Concurrency
+{
+    public interface IRunnable
+    {
+        void Run();
+    }
+}

HashedWheelTimer/Concurrency/RejectedExecutionException.cs

@@ -0,0 +1,19 @@
+// Copyright (c) Microsoft. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+namespace WheelTimer.Concurrency
+{
+    using System;
+
+    public class RejectedExecutionException : Exception
+    {
+        public RejectedExecutionException()
+        {
+        }
+
+        public RejectedExecutionException(string message)
+            : base(message)
+        {
+        }
+    }
+}

HashedWheelTimer/Concurrency/TaskCompletionSource.cs

@@ -0,0 +1,37 @@
+// Copyright (c) Microsoft. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+namespace WheelTimer.Concurrency
+{
+    using System.Threading.Tasks;
+
+    public sealed class TaskCompletionSource : TaskCompletionSource<int>
+    {
+        public static readonly TaskCompletionSource Void = CreateVoidTcs();
+
+        public TaskCompletionSource(object state)
+            : base(state)
+        {
+        }
+
+        public TaskCompletionSource()
+        {
+        }
+
+        public bool TryComplete() => TrySetResult(0);
+
+        public void Complete() => SetResult(0);
+
+        // todo: support cancellation token where used
+        public bool SetUncancellable() => true;
+
+        public override string ToString() => "TaskCompletionSource[status: " + Task.Status.ToString() + "]";
+
+        static TaskCompletionSource CreateVoidTcs()
+        {
+            var tcs = new TaskCompletionSource();
+            tcs.TryComplete();
+            return tcs;
+        }
+    }
+}