C#线程安全及lock使用

2020-09-09  本文已影响0人  浅谈码生活

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只读。

上一篇 下一篇

猜你喜欢

热点阅读