Parallel 并行编程

Parallel==Task+waitall（将主线程也利用了起来，改进了Task）
Invoke()

Parallel.Invoke(() =>
this.DoSomethingLong("btnParallel_Click_0")
 , () => this.DoSomethingLong("btnParallel_Click_1")
 , () => this.DoSomethingLong("btnParallel_Click_2")
 , () => this.DoSomethingLong("btnParallel_Click_3")
 , () => this.DoSomethingLong("btnParallel_Click_4")
 , () => this.DoSomethingLong("btnParallel_Click_5"));

For()

Parallel.For(0, 5, t => this.DoSomethingLong($"btnParallel_Click_{t}"));

Foreach()  （可以利用ParallelOptions设置最大并发数）

Parallel.ForEach(new int[] { 1, 2, 3, 4, 5 }, t => this.DoSomethingLong($"btnParallel_Click_{t}"));

ParallelOptions option = new ParallelOptions()
{
    MaxDegreeOfParallelism = 3//最大并发数
};
Parallel.ForEach(new int[] { 1, 2, 3, 4, 5, 6 }, option, t =>
{
    this.DoSomethingLong($"btnParallel_Click_{t}");
});

new Action(() =>
{
ParallelOptions option = new ParallelOptions()
{
    MaxDegreeOfParallelism = 3//最大并发数
};
Parallel.ForEach(new int[] { 1, 2, 3, 4, 5, 6 }, option, t =>
{
    this.DoSomethingLong($"btnParallel_Click_{t}");
});
}).BeginInvoke(null, null);

结束线程 Break和Stop

ParallelOptions option = new ParallelOptions()
{
    MaxDegreeOfParallelism = 3//最大并发数
};
Parallel.ForEach(new int[] { 1, 2, 3, 4, 5, 6 }, option, (t, state) =>
{
    this.DoSomethingLong($"btnParallel_Click_{t}");
    //state.Break();//这一次结束
    //return;

    state.Stop();//整个Parallel结束
    return;
    //不能共存
});

多线程的异常处理（主线程抓不到子线程的异常）

                异常被吞掉了，加上waitall才能抓取到异常
                Task.WaitAll(taskList.ToArray());

（主线程）红色字体处捕获异常，但是异常已经发生（主线程抓不到子线程的异常）且其他的子线程已经执行（亡羊补牢，为时已晚）。所以，最好在子线程处处理异常，加上Task.WaitAll（）。

try
            {
                TaskFactory taskFactory = new TaskFactory();
                List<Task> taskList = new List<Task>();
                #region 异常处理
                ////在线程Action加上try catch，日志记录，不抛异常
                //for (int i = 0; i < 20; i++)
                //{
                //    string name = string.Format($"btnThreadCore_Click_{i}");
                //    Action<object> act = t =>
                //    {
                //        try//---------------------------------------------------------------子线程处理异常
                //        {
                //            Thread.Sleep(2000);
                //            if (t.ToString().Equals("btnThreadCore_Click_11"))
                //            {
                //                throw new Exception(string.Format($"{t} 执行失败"));
                //            }
                //            if (t.ToString().Equals("btnThreadCore_Click_12"))
                //            {
                //                throw new Exception(string.Format($"{t} 执行失败"));
                //            }
                //            Console.WriteLine("{0} 执行成功", t);
                //        }
                //        catch (Exception ex)
                //        {
                //            Console.WriteLine(ex.Message);
                //        }//-----------------------------------------------------------------子线程处理异常
                //    };
                //    taskList.Add(taskFactory.StartNew(act, name));
                //}
                ////异常被吞掉了，加上waitall才能抓取到异常
 33                 ////Task.WaitAll(taskList.ToArray());
                #endregion

                #region 线程取消
                ////线程间都是通过共有变量：都能访问局部变量/全局变量/数据库的一个值/硬盘文件
                ////线程不能被外部停止，只能自身停止自身；或者在任务启动前停止，会抛出异常的
                //CancellationTokenSource cts = new CancellationTokenSource();
                //for (int i = 0; i < 40; i++)
                //{
                //    string name = string.Format("btnThreadCore_Click{0}", i);
                //    Action<object> act = t =>
                //    {
                //        try
                //        {
                //            //if (cts.IsCancellationRequested)
                //            //{
                //            //    Console.WriteLine("{0} 取消一个任务的执行", t);
                //            //}
                //            Thread.Sleep(2000);
                //            if (t.ToString().Equals("btnThreadCore_Click11"))
                //            {
                //                throw new Exception(string.Format("{0} 执行失败", t));
                //            }
                //            if (t.ToString().Equals("btnThreadCore_Click12"))
                //            {
                //                throw new Exception(string.Format("{0} 执行失败", t));
                //            }
                //            if (cts.IsCancellationRequested)//检查信号量
                //            {
                //                Console.WriteLine("{0} 放弃执行", t);
                //            }
                //            else
                //            {
                //                Console.WriteLine("{0} 执行成功", t);
                //            }
                //        }
                //        catch (Exception ex)
                //        {
                //            cts.Cancel();//表示修改了信号量  让大家取消执行
                //            Console.WriteLine(ex.Message);
                //        }
                //    };
                //    taskList.Add(taskFactory.StartNew(act, name, cts.Token));//没有启动的任务  在Cancel后放弃启动
                //}
                //Task.WaitAll(taskList.ToArray());
                #endregion

                #region 多线程临时变量
                //for (int i = 0; i < 5; i++)
                //{
                //    int k = i;
                //    new Action(() =>
                //    {
                //        Thread.Sleep(100);
                //        //Console.WriteLine(i);
                //        Console.WriteLine(k);
                //    }).BeginInvoke(null, null);
                //}
                #endregion

                #region 线程安全 lock
                //共有变量：都能访问局部变量/全局变量/数据库的一个值/硬盘文件
                for (int i = 0; i < 10000; i++)
                {
                    int newI = i;
                    taskList.Add(taskFactory.StartNew(() =>
                    {
                        lock (btnThreadCore_Click_Lock)//lock后的方法块，任意时刻只有一个线程可以进入
                        {//这里就是单线程
                            this.TotalCount += 1;
                            IntList.Add(newI);
                        }
                    }));
                }
                Task.WaitAll(taskList.ToArray());

                Console.WriteLine(this.TotalCount);
                Console.WriteLine(IntList.Count());
                #endregion
            }
            catch (AggregateException aex)//-------------------------------------------主线程捕获异常
114             {
115                 foreach (var item in aex.InnerExceptions)
116                 {
117                     Console.WriteLine(item.Message);
118                 }
119             }
120             catch (Exception ex)
121             {
122                 Console.WriteLine(ex.Message);
123             }