using System;
using System.Threading;
namespace ConsoleApplication1
{
class Program
{
private static AutoResetEvent[] events;
static void Main( string [] args)
{
int threadNum = 10;
Thread[] thread = new Thread[threadNum];
events = new AutoResetEvent[threadNum];
for ( int i = 0; i < threadNum; i++)
{
var waithandler = new AutoResetEvent( false );
events[i] = waithandler;
ThreadStart starter = delegate
{
var param = new Tuple< string , AutoResetEvent>( "test print:" + i, waithandler);
Print(param);
};
thread[i] = new Thread(starter)
{
Name = "thread" + i.ToString()
};
}
for ( int i = 0; i < threadNum; i++)
{
thread[i].Start();
}
WaitHandle.WaitAll(events);
Console.WriteLine( "Completed!" );
Console.Read();
}
private static void Print( object param)
{
var p = (Tuple< string , AutoResetEvent>)param;
Console.WriteLine(Thread.CurrentThread.Name + ": Begin!" );
Console.WriteLine(Thread.CurrentThread.Name + ": Print" + p.Item1);
Thread.Sleep(300);
Console.WriteLine(Thread.CurrentThread.Name + ": End!" );
p.Item2.Set();
}
}
}
|