Csharp/C Sharp by API/System.Threading/ThreadPool

ThreadPool.QueueUserWorkItem

<source lang="csharp"> using System; using System.Collections.Generic; using System.Text; using System.Threading; using System.Reflection; using System.Reflection.Emit; public class MainClass {

   public static void Main()
   {
       ThreadPool.QueueUserWorkItem(delegate {
           Console.WriteLine(Assembly.GetCallingAssembly().FullName);
       });
       Thread.Sleep(100);
   }

}

 </source>

ThreadPool.RegisterWaitForSingleObject

<source lang="csharp"> using System; using System.Threading; class MainClass {

   private static void EventHandler(object state, bool timedout) 
   {
       Console.WriteLine("timedout:"+timedout);
       Console.WriteLine("state:"+state);
       Console.WriteLine(DateTime.Now.ToString("HH:mm:ss.ffff"));
   }
   public static void Main() 
   {
       AutoResetEvent autoEvent = new AutoResetEvent(false);
       string state = "AutoResetEvent signaled.";
       RegisteredWaitHandle handle = ThreadPool.RegisterWaitForSingleObject(
           autoEvent, EventHandler, state, 3000, false);

       Thread.Sleep(5000);
       
       autoEvent.Set();
       
       Console.WriteLine("Unregistering wait operation.");
       handle.Unregister(null);
   }

}

 </source>

ThreadPool.SetMaxThreads

<source lang="csharp"> using System; using System.IO; using System.Net; using System.Text; using System.Threading; class WebServer {

   HttpListener myListener;
   string _baseFolder;     
   public WebServer(string uriPrefix, string baseFolder) {
       System.Threading.ThreadPool.SetMaxThreads(50, 1000);
       System.Threading.ThreadPool.SetMinThreads(50, 50);
       myListener = new HttpListener();
       myListener.Prefixes.Add(uriPrefix);
       _baseFolder = baseFolder;
   }
   public void Start() {                       
       myListener.Start();
       while (true)
           try {
               HttpListenerContext request = myListener.GetContext();
               ThreadPool.QueueUserWorkItem(ProcessRequest, request);
           } catch (HttpListenerException) { break; }  
           catch (InvalidOperationException) { break; }
   }
   public void Stop() { 
      myListener.Stop(); 
   }
   void ProcessRequest(object listenerContext) {
       try {
           var context = (HttpListenerContext)listenerContext;
           string filename = Path.GetFileName(context.Request.RawUrl);
           string path = Path.rubine(_baseFolder, filename);
           byte[] msg;
           if (!File.Exists(path)) {
               context.Response.StatusCode = (int)HttpStatusCode.NotFound;
               msg = Encoding.UTF8.GetBytes("Sorry, that page does not exist");
           } else {
               context.Response.StatusCode = (int)HttpStatusCode.OK;
               msg = File.ReadAllBytes(path);
           }
           context.Response.ContentLength64 = msg.Length;
           using (Stream s = context.Response.OutputStream)
               s.Write(msg, 0, msg.Length);
       } catch (Exception ex) { Console.WriteLine("Request error: " + ex); }
   }

}

 </source>