美文网首页
C#线程安全及lock使用

C#线程安全及lock使用

作者: 浅谈码生活 | 来源:发表于2020-09-09 11:13 被阅读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只读。

相关文章

  • C#线程安全及lock使用

    1.首先我们先探讨一下当我们的子线程内部发生异常之后,该线程将会直接停止,确没有将异常抛出,这时我们将会如何处理呢...

  • C#学习笔记

    C#中的线程(一)入门 C#中的线程(二) 线程同步基础 C#中的线程(三) 使用多线程 20190130补充: ...

  • 12.Lock

    之前在使用synchronized解决线程安全问题时,经常提到用lock也可以实现synchronized的功能,...

  • JUC源码分析-集合篇(七):PriorityBlockingQ

    PriorityBlockingQueue 是二叉堆结构的无界优先级阻塞队列,使用显示锁 Lock 保证线程安全,...

  • 简单实现自己的Lock

    简述 我们知道使用ReentrantLock可以实现同步,保证线程安全,下面我们来简单实现自己的Lock 实现 我...

  • java并发编程之原子类

    当多个线程同时更新公共变量,会导致线程不安全,通常大家可以会想到使用synchronized关键字或者Lock来解...

  • 深度剖析 JDK7 ConcurrentHashMap 中的知识

    Lock Stripping 在 Java 中,普通的 HashMap 是非线程安全的,HashTable 是线程...

  • 线程安全

    常见的线程安全操作 ①加锁同步synchronized Lock等 ②wait() notify()线程调度 已实...

  • Reentreantlock里lock和trylock的区别

    举一个例子如下: 假如线程A和线程B使用同一个锁LOCK,此时线程A首先获取到锁LOCK.lock(),并且始终持...

  • JAVA 并发 编程系列 (二)锁 之 ReentrantLoc

    java 中的锁 Lock接口 使用ReentrantLock实现线程同步 结果 使用Lock对象和Conditi...

网友评论

      本文标题:C#线程安全及lock使用

      本文链接:https://www.haomeiwen.com/subject/icqeektx.html