ConsoleWorker.cs

using System.Threading.Tasks;
using Waher.Events;
using Waher.Runtime.Queue;
 
namespace Waher.Runtime.Console.Worker
{
    public static class ConsoleWorker
    {
        private static AsyncProcessor<WorkItem> worker = new AsyncProcessor<WorkItem>(1, "Console Output");
 
        static ConsoleWorker()
        {
            Log.Terminating += Log_Terminating;
        }
 
        private static async Task Log_Terminating(object Sender, System.EventArgs e)
        {
            await Terminate();
            Log.Terminating -= Log_Terminating;
        }
 
        internal static async Task Terminate()
        {
            if (!(worker is null))
            {
                await worker.DisposeAsync();
                worker = null;
            }
        }
 
        public static Task<bool> Forward(WorkItem Work)
        {
            return worker?.Forward(Work) ?? Task.FromResult(false);
        }
 
        public static bool Terminating => worker?.Terminating ?? true;
 
        public static bool Terminated => worker?.Terminated ?? true;
    }
}