Blog.NotesOnThreading\Program_Local.cs

using System;
using System.Threading;
using System.Threading.Tasks;

namespace Blog.NotesOnThreading
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine(Environment.ProcessorCount);
            ThreadPool.SetMinThreads(8, 8);
            
            while (true)
            {
                ThreadPool.QueueUserWorkItem(
                    arg =>
                    {
                        Process();
                    }); 
                
                Thread.Sleep(10);
            }
        }

        static void Process()
        {
            var completionFlag = new ManualResetEventSlim(false);
            
            ThreadPool.QueueUserWorkItem(
                evt =>
                {
                    Thread.Sleep(1000);
                    evt.Set();
                    
                }, completionFlag, preferLocal: true); 
            
            completionFlag.Wait();
            
            Console.WriteLine($"{nameof(Process)} completed - {DateTime.Now.ToLongTimeString()} " +
                              $"| Pending work count: {ThreadPool.PendingWorkItemCount}");
        }
    }
}