.Net并行编程

在微软的.NET Framework中，任务是通过System.Threading.Tasks命令空间中的Task类来实现的。它的静态属性Task.Factory是TaskFactory类的一个实例，它被用来创建和调度新任务。

调度是并行任务的一个重要方面。新任务并不一定会像线程那样直接开始运行，而是被放在一个工作队列里面。

示例代码 

有两个方法，DoLeft()

public static void DoLeft()
{
    Thread.Sleep(10000);
    Console.WriteLine(string.Concat(DateTime.Now.ToLongTimeString(), " DoLeft is running!"));
}

和DoRight()

public static void DoRight()
{
    Thread.Sleep(2000);
    Console.WriteLine(string.Concat(DateTime.Now.ToLongTimeString(), " DoRight is running!"));
}

我们来并行的执行这两个任务。

• Parallel.Invoke方式

static void Main(string[] args)
{
    Stopwatch sw = new Stopwatch();
    sw.Start();

    Parallel.Invoke(DoLeft, DoRight);

    sw.Stop();
    Console.WriteLine(string.Format("共计耗时{0}秒", sw.Elapsed.TotalSeconds));

    Console.Read();
}

运行结果为：

运行结果表明Parallel.Invoke方法创建了新任务并等待它们完成。

• Task.Factory.StartNew方法

调用方法变更为：

static void Main(string[] args)
{
    Stopwatch sw = new Stopwatch();
    sw.Start();

    var task1 = Task.Factory.StartNew(DoLeft);      //StartNew, 创建并启动System.Threading.Tasks.Task
    var task2 = Task.Factory.StartNew(DoRight);

    sw.Stop();
    Console.WriteLine(string.Format("共计耗时{0}秒", sw.Elapsed.TotalSeconds));

    Console.Read();
}

运行结果：

从结果可以得出，TaskFactory类的StartNew方法会创建并调度一个新任务，并不等待任务执行完成。添加Task.WaitAll来等待所有并行任务执行完成。

Task.WaitAll(task1, task2);

可以看出其是在等待tasks全部执行完成。