AsyncProcessors.cs

using System.Collections.Generic;
using System.Threading.Tasks;
 
namespace Waher.Runtime.Queue
{
    public static class AsyncProcessors
    {
        private static readonly LinkedList<IAsyncProcessor> activeProcessors = new LinkedList<IAsyncProcessor>();
 
        internal static LinkedListNode<IAsyncProcessor> RegisterProcessor(IAsyncProcessor Processor)
        {
            lock (activeProcessors)
            {
                return activeProcessors.AddLast(Processor);
            }
        }
 
        internal static void UnregisterProcessor(LinkedListNode<IAsyncProcessor> Node)
        {
            if (!(Node is null))
            {
                lock (activeProcessors)
                {
                    if (!(Node.List is null))
                        activeProcessors.Remove(Node);
                }
            }
        }
 
        public static IAsyncProcessor[] GetActiveProcessors()
        {
            lock (activeProcessors)
            {
                IAsyncProcessor[] Result = new IAsyncProcessor[activeProcessors.Count];
                activeProcessors.CopyTo(Result, 0);
                return Result;
            }
        }
 
        public static bool HasActiveProcessors
        {
            get
            {
                lock (activeProcessors)
                {
                    return !(activeProcessors.First is null);
                }
            }
        }
 
        public static Task CloseAllProcessorsForTermination()
        {
            return CloseAllProcessorsForTermination(false, 0);
        }
 
        public static Task CloseAllProcessorsForTermination(bool WaitForCompletion)
        {
            return CloseAllProcessorsForTermination(WaitForCompletion, int.MaxValue);
        }
 
        public static async Task CloseAllProcessorsForTermination(bool WaitForCompletion, int Timeout)
        {
            IAsyncProcessor[] Processors = GetActiveProcessors();
            int i, c = Processors.Length;
            Task[] Tasks = new Task[c];
 
            for (i = 0; i < c; i++)
                Tasks[i] = Processors[i].CloseForTermination(WaitForCompletion, Timeout);
 
            if (WaitForCompletion)
                await Task.WhenAll(Tasks);
        }
    }
}