patricksuo/threadpool_perf.cs

## threadpool_perf.cs
using System;

namespace threadpool_bench
{
    class Program
    {
        static int totalRound;
        static System.Threading.ManualResetEventSlim finishEvent;

        static System.Threading.WaitCallback job = obj =>
        {
            var old = System.Threading.Interlocked.Decrement(ref totalRound);
            if (old > 0)
            {
                System.Threading.ThreadPool.QueueUserWorkItem(job);
            }
            else if (old == 0)
            {
                finishEvent.Set();
            }
        };

        static void Main(string[] args)
        {
            Console.WriteLine("Hello World!");
            for (var i = 0; i < 10; i++)
            {
                System.Diagnostics.Stopwatch watcher = new System.Diagnostics.Stopwatch();
                finishEvent = new System.Threading.ManualResetEventSlim();
                watcher.Start();
                totalRound = 100 * 100000;
                for (var j = 0; j < 1000; j++)
                {
                    System.Threading.ThreadPool.QueueUserWorkItem(job);
                }
                finishEvent.Wait();
                watcher.Stop();
                Console.WriteLine("round {0} time {1}", i, watcher.ElapsedMilliseconds);
                finishEvent.Wait(500);

            }
        }
    }
}
	using System;

	namespace threadpool_bench
	{
	class Program
	{
	static int totalRound;
	static System.Threading.ManualResetEventSlim finishEvent;

	static System.Threading.WaitCallback job = obj =>
	{
	var old = System.Threading.Interlocked.Decrement(ref totalRound);
	if (old > 0)
	{
	System.Threading.ThreadPool.QueueUserWorkItem(job);
	}
	else if (old == 0)
	{
	finishEvent.Set();
	}
	};

	static void Main(string[] args)
	{
	Console.WriteLine("Hello World!");
	for (var i = 0; i < 10; i++)
	{
	System.Diagnostics.Stopwatch watcher = new System.Diagnostics.Stopwatch();
	finishEvent = new System.Threading.ManualResetEventSlim();
	watcher.Start();
	totalRound = 100 * 100000;
	for (var j = 0; j < 1000; j++)
	{
	System.Threading.ThreadPool.QueueUserWorkItem(job);
	}
	finishEvent.Wait();
	watcher.Stop();
	Console.WriteLine("round {0} time {1}", i, watcher.ElapsedMilliseconds);
	finishEvent.Wait(500);

	}
	}
	}
	}