上一篇：异步多线程之入Task
下一篇：异步多线程使用中的常见问题

---

简介

Parallel 叫做并行编程 .Net 4.5 时代的，基于 Task 基础上做了封装。Parallel 的特点方便控制线程并发数量与节省一个线程。

API

Parallel 相对来说也比较简单，这里介绍几个 API（Invoke、For、ForEach）的用法，这三个 API 都可以节约一个线程。

Invoke

例如：Invoke 方法可以做并发，传入委托即可。这里并发 3 任务，如下

public static void Coding(string name, string module)
{
    
    Console.WriteLine($"{
      name} Coding Start {
      module}，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");

    Console.WriteLine($"{
      name} Coding End  {
      module}，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");
}

static void Main(string[] args)
{
    
    Console.WriteLine($"Main Start，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");

    Parallel.Invoke(() => Coding("张三", "Web"), () => Coding("李四", "Service"), () => Coding("王五", "SQL"));

    Console.WriteLine($"Main End，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");

    Console.ReadLine();
}

启动程序，可以看到 3 个任务并发执行，会卡界面。但只有三个线程（1-主线程，3、4-子线程），节约一个线程。

For

For 也是一样的，主线程参与计算，节约一个线程。

public static void Coding(string name, string module)
{
    
    Console.WriteLine($"{
      name} Coding Start {
      module}，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");

    Console.WriteLine($"{
      name} Coding End  {
      module}，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");
}

static void Main(string[] args)
{
    
    Console.WriteLine($"Main Start，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");

    Parallel.For(0, 5, i =>
    {
    

        Coding("张三"+ i.ToString(), "Web" + i.ToString());
    });

    Console.WriteLine($"Main End，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");

    Console.ReadLine();
}

ForEach

For 也是一样的，主线程参与计算，节约一个线程。

public static void Coding(string name, string module)
{
    
    Console.WriteLine($"{
      name} Coding Start {
      module}，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");

    Console.WriteLine($"{
      name} Coding End  {
      module}，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");
}

static void Main(string[] args)
{
    
    Console.WriteLine($"Main Start，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");

    Parallel.ForEach(new int[] {
     2, 4, 6, 8 }, i =>
        {
    
            Coding("张三" + i.ToString(), "Web" + i.ToString());
        });

    Console.WriteLine($"Main End，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");

    Console.ReadLine();
}

限定线程数量

Parallel 限定线程数量也是比较简单的，使用 ParallelOptions 设置一下即可。如下

public static void Coding(string name, string module)
{
    
    Console.WriteLine($"{
      name} Coding Start {
      module}，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");

    Console.WriteLine($"{
      name} Coding End  {
      module}，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");
}

static void Main(string[] args)
{
    
    Console.WriteLine($"Main Start，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");

    ParallelOptions parallelOptions = new ParallelOptions();
    parallelOptions.MaxDegreeOfParallelism = 3;
    Parallel.For(0, 10, parallelOptions, i =>
    {
    

        Coding("张三" + i.ToString(), "Web" + i.ToString());
    });

    Console.WriteLine($"Main End，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");

    Console.ReadLine();
}

如何不卡线程？答案：还是老套路，包一层。如下

public static void Coding(string name, string module)
{
    
    Console.WriteLine($"{
      name} Coding Start {
      module}，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");

    Console.WriteLine($"{
      name} Coding End  {
      module}，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");
}

static void Main(string[] args)
{
    
    Console.WriteLine($"Main Start，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");

    Task.Run(() =>
    {
    
        ParallelOptions parallelOptions = new ParallelOptions();
        parallelOptions.MaxDegreeOfParallelism = 3;
        Parallel.For(0, 10, parallelOptions, i =>
        {
    
            Coding("张三" + i.ToString(), "Web" + i.ToString());
        });
    });

    Console.WriteLine($"Main End，ThreadId：{
      Thread.CurrentThread.ManagedThreadId}，Datetime：{
      DateTime.Now.ToLongTimeString()}");

    Console.ReadLine();
}