C#线程安全及lock使用

1.首先我们先探讨一下当我们的子线程内部发生异常之后，该线程将会直接停止，确没有将异常抛出，这时我们将会如何处理呢？
1.）List 存入所有的Task;
2.)Task.WaitAll()可以捕捉到AggregateException类型异常；
3.)可以多个Cath来捕捉异常，异常--先具体再抽象；
4.)可以通过aex.InnerExceptions获取到多线程中所有的异常;
2.如果当多线程同时执行业务，而其中一个线程出现异常，如何将其他线程马上停止下来，重新开始操作？

//使用CancellationTokenSource
try
{
    CancellationTokenSource cts = new CancellationTokenSource();
    List<Task> taskList = new List<Task>();
    for (int i = 0; i < 100; i++)
    {
        Thread.Sleep(new Random().Next(100, 300));
        string name = $"btnTask_Click_{i}";
        taskList.Add(Task.Run(() =>
       {      
           if (name.Equals("btnTask_Click_Click_8"))
           {
               cts.Cancel(); //就可以把IsCancellationRequested指定为true; 
               throw new Exception("btnTask_Click_8  异常了。。。");
           }
           else if (name.Equals("btnTask_Click_13"))
           {
               cts.Cancel(); //就可以把IsCancellationRequested指定为true; 
               throw new Exception("btnTask_Click_13  异常了。。。");
           }
           else if (name.Equals("btnTask_Click_25"))
           {
               cts.Cancel(); //就可以把IsCancellationRequested指定为true; 
               throw new Exception("btnTask_Click_25  异常了。。。");
           }
           //如果有业务需要，其实也可以直接Cancel()，其他的线程也都停止下来了；
           if (!cts.IsCancellationRequested)
           {
               Console.WriteLine($"{name}  End.....{Thread.CurrentThread.ManagedThreadId.ToString("00")}");
           }
           else
           {
               Console.WriteLine($"{name} 失败了.....{Thread.CurrentThread.ManagedThreadId.ToString("00")}");
           }
           Console.WriteLine($"this is {name} 成功， ThreadID={Thread.CurrentThread.ManagedThreadId.ToString("00")}");
       }, cts.Token)); //只需要把cts.Token 给Task.run()
    }
    Task.WaitAll(taskList.ToArray());
}
catch (AggregateException aex)
{
    foreach (var exception in aex.InnerExceptions)
    {
        Console.WriteLine(exception.Message);
    }
}

3.线程安全&lock
线程安全：using System.Collections.Concurrent;
1.）BlockingCollection<T> 为实现 IProducerConsumerCollection<T> 的线程安全集合提供阻塞和限制功能。
2.）ConcurrentBag<T> 表示对象的线程安全的无序集合。
3.）ConcurrentDictionary<TKey, TValue> 表示可由多个线程同时访问的键值对的线程安全集合。
4.）ConcurrentQueue<T> 表示线程安全的先进先出 (FIFO) 集合。
5.）ConcurrentStack<T> 表示线程安全的后进先出 (LIFO) 集合。
6.）OrderablePartitioner<TSource> 表示将一个可排序数据源拆分成多个分区的特定方式。
7.）Partitioner 提供针对数组、列表和可枚举项的常见分区策略。
8.）Partitioner<TSource> 表示将一个数据源拆分成多个分区的特定方式。
Lock：锁，排他性，标准锁，锁对象必须为引用类型，但不可用“string”类型（可以具体了解String类型值是如何存储的）。
标准格式：private static readonly object obj_From = new object(); static --不会被释放，readonly只读。

最后编辑于：2020.09.09 11:25:41