AutoResetEvent

gistfile1.cs

using System.IO;
using System.Text;
using System.Threading;
using System.Net;
using System;

class Program
{
	private static AutoResetEvent autoEvent = new AutoResetEvent(false);
	private static AutoResetEvent autoEvent2 = new AutoResetEvent(false);
	
	public static void Main()
	{
		HttpListener listener = new HttpListener();

		var url = "http://localhost:2999/";
		listener.Prefixes.Add(url);
	
		listener.Start();
		Console.WriteLine("Listening...");

		for (var i = 0; i < 20; i++)
			CreateListenerRequest (listener, url);

		Console.ReadLine();
	}

	public static void CreateListenerRequest (HttpListener listener, string uri)
	{
		Console.WriteLine("BeginGetContext...");
		var asyncResult = listener.BeginGetContext (ListenerCallback, listener);

		var request = (HttpWebRequest) WebRequest.Create(uri);
		request.Method = "POST";

		using (var writer = new StreamWriter(request.GetRequestStream(), Encoding.ASCII))
			writer.Write ("request");

		// send request
		var response = request.GetResponse ();
		response.Close ();

		asyncResult.AsyncWaitHandle.WaitOne();
	}
	
	public static void ListenerCallback(IAsyncResult result)
	{
		Console.WriteLine("ListenerCallback...");
	
		autoEvent.Set();
		//Thread.Sleep(10);
		autoEvent.Reset();
	
		HttpListener listener = (HttpListener)result.AsyncState;
		HttpListenerContext context = listener.EndGetContext(result);
	
		context.Request.InputStream.Close ();
		context.Response.OutputStream.Close();
	
		int res = WaitHandleNext();
	
		if (res == 0 || res == 1)
		{
			// Never get this line
			Console.WriteLine("Done...");
		}
		else if (res == WaitHandle.WaitTimeout)
		{
			// Always here
			Console.WriteLine("Done by timeout");
		}
	}
	
	private static int WaitHandleNext()
	{
		Console.WriteLine("WaitHandleNext...");
		int waitResult = WaitHandle.WaitAny(new[] { autoEvent, autoEvent2 },
			TimeSpan.FromSeconds(30), false);
		return waitResult;
	}
}