Refactoring.

Version 0.0.4.

Author: konard

ConcurrentQueueExtensions.cs

@@ -10,13 +10,17 @@ public static class ConcurrentQueueExtensions
         public static async Task AwaitAll(this ConcurrentQueue<Task> queue)
         {
             foreach (var item in queue.DequeueAll())
+            {
                 await item;
+            }
         }
 
         public static async Task AwaitOne(this ConcurrentQueue<Task> queue)
         {
             if (queue.TryDequeue(out Task item))
+            {
                 await item;
+            }
         }
 
         public static void EnqueueAsRunnedTask(this ConcurrentQueue<Task> queue, Action action) => queue.Enqueue(Task.Run(action));

Platform.Threading.csproj

@@ -4,7 +4,7 @@
     <Description>LinksPlatform's Platform.Threading Class Library</Description>
     <Copyright>Konstantin Diachenko</Copyright>
     <AssemblyTitle>Platform.Threading</AssemblyTitle>
-    <VersionPrefix>0.0.3</VersionPrefix>
+    <VersionPrefix>0.0.4</VersionPrefix>
     <Authors>Konstantin Diachenko</Authors>
     <TargetFramework>netstandard2.0</TargetFramework>
     <AssemblyName>Platform.Threading</AssemblyName>
@@ -21,6 +21,8 @@
     <GenerateAssemblyProductAttribute>false</GenerateAssemblyProductAttribute>
     <IncludeSymbols>true</IncludeSymbols>
     <SymbolPackageFormat>snupkg</SymbolPackageFormat>
+    <PackageReleaseNotes>Platform.Collections updated to 0.0.3 version.
+Refactoring.</PackageReleaseNotes>
   </PropertyGroup>
 
   <ItemGroup>

README.md

@@ -6,6 +6,6 @@ LinksPlatform's Platform.Threading Class Library.
 
 Namespace: Platform.Threading
 
-Forked from: https://github.com/Konard/LinksPlatform/tree/b41aac7909066bb746c7f8e29a1cd59710e5b0d5/Platform/Platform.Helpers/Threading
+Forked from: [Konard/LinksPlatform/Platform/Platform.Helpers/Threading](https://github.com/Konard/LinksPlatform/tree/b41aac7909066bb746c7f8e29a1cd59710e5b0d5/Platform/Platform.Helpers/Threading)
 
-NuGet package: https://www.nuget.org/packages/Platform.Threading
+NuGet package: [Platform.Threading](https://www.nuget.org/packages/Platform.Threading)

Synchronization/ISynchronized.cs

@@ -1,10 +1,11 @@
 namespace Platform.Threading.Synchronization
 {
     /// <summary>
-    /// Represents extendable sychronized interface access gate.
+    /// Represents extendable synchronized interface access gate.
+    /// Представляет расширяемый интерфейс шлюза синхронизированного доступа.
     /// </summary>
-    /// <typeparam name="TInterface">Sychronized interface.</typeparam>
-    public interface ISynchronized<TInterface>
+    /// <typeparam name="TInterface">Synchronized interface. Синхронизируемый интерфейс.</typeparam>
+    public interface ISynchronized<out TInterface>
     {
         /// <summary>
         /// Gets sychronization method.

Synchronization/ReaderWriterLockSynchronization.cs

@@ -3,9 +3,6 @@
 
 namespace Platform.Threading.Synchronization
 {
-    /// <summary>
-    /// TODO: Сравнить что производительнее использовать анонимную функцию или using (создание объекта + dispose)
-    /// </summary>
     public class ReaderWriterLockSynchronization : ISynchronization
     {
         private readonly ReaderWriterLockSlim _rwLock = new ReaderWriterLockSlim(LockRecursionPolicy.SupportsRecursion);

Synchronization/SynchronizationExtensions.cs

@@ -2,9 +2,6 @@
 
 namespace Platform.Threading.Synchronization
 {
-    /// <remarks>
-    /// TODO: Избавиться от анонимных функций передаваемых в ExecuteReadOperation и ExecureWriteOperation
-    /// </remarks>
     public static class SynchronizationExtensions
     {
         public static TResult ExecuteReadOperation<TResult, TParam>(this ISynchronization synchronization, TParam parameter, Func<TParam, TResult> function) => synchronization.ExecuteReadOperation(() => function(parameter));

ThreadHelpers.cs

@@ -5,22 +5,30 @@ namespace Platform.Threading
 {
     public static class ThreadHelpers
     {
-        public const int DefaultMaxStackSize = 0;
-        public const int DefaultSleepTimeout = 1;
-        public const int ExtendedMaxStackSize = 200 * 1024 * 1024;
+        public static readonly int DefaultMaxStackSize = 0;
+        public static readonly int ExtendedMaxStackSize = 200 * 1024 * 1024;
+        public static readonly int DefaultSleepTimeout = 1;
 
-        public static void SyncInvokeWithExtendedStack<T>(T param, Action<object> action, int maxStackSize = ExtendedMaxStackSize) => StartNew(param, action, maxStackSize).Join();
+        public static void SyncInvokeWithExtendedStack<T>(T param, Action<object> action) => SyncInvokeWithExtendedStack(param, action, ExtendedMaxStackSize);
 
-        public static void SyncInvokeWithExtendedStack(Action action, int maxStackSize = ExtendedMaxStackSize) => StartNew(action, maxStackSize).Join();
+        public static void SyncInvokeWithExtendedStack<T>(T param, Action<object> action, int maxStackSize) => StartNew(param, action, maxStackSize).Join();
 
-        public static Thread StartNew<T>(T param, Action<object> action, int maxStackSize = DefaultMaxStackSize)
+        public static void SyncInvokeWithExtendedStack(Action action) => SyncInvokeWithExtendedStack(action, ExtendedMaxStackSize);
+
+        public static void SyncInvokeWithExtendedStack(Action action, int maxStackSize) => StartNew(action, maxStackSize).Join();
+
+        public static Thread StartNew<T>(T param, Action<object> action) => StartNew(param, action, DefaultMaxStackSize);
+
+        public static Thread StartNew<T>(T param, Action<object> action, int maxStackSize)
         {
             var thread = new Thread(new ParameterizedThreadStart(action), maxStackSize);
             thread.Start(param);
             return thread;
         }
 
-        public static Thread StartNew(Action action, int maxStackSize = DefaultMaxStackSize)
+        public static Thread StartNew(Action action) => StartNew(action, DefaultMaxStackSize);
+
+        public static Thread StartNew(Action action, int maxStackSize)
         {
             var thread = new Thread(new ThreadStart(action), maxStackSize);
             thread.Start();