C#多线程之线程绑定ThreadLocal类

在.Net 4.0的Thread里，新增了线程局部变量（ThreadLocal）类，可以很方便的实现线程专有存储。

应用场景

线程专有存储应被用于这样的多线程应用：它们经常访问那些逻辑上是全局的、而物理上是专有于每个线程的对象。首先我们看如下这样一个例子

    string errorMessage;

    void Process()
    {
        bool ret = Run();
        if (!ret && needDebug)
        {
            Console.WriteLine(errorMessage);
        }
    }

    bool Run()
    {
        try
        {
            //…-- do something
            return true;
        }
        catch (Exception e)
        {
            errorMessage = e.Message;
            return false;
        }
    }

这个函数中，Process为主体函数，当它调用Run函数失败后，为调式方便，打出Run函数的错误信息。错误信息采用成员变量errorMessage存放，为了减少Run函数的参数。

这种通过成员变量errorMessage在函数间传递信息的方式在单线程程序中可以很好的工作，但是在多线程应用时却往往会发生一些微妙的问题：当两个线程同时执行Run函数时，先执行的会被后执行的线程覆盖，导致输出了错误的后执行的线程的调试信息。发生类似数据库的脏读错误。

解决方案：

最直接的解决方案有两种：

加锁：在Process中加锁，保证没有两个线程同时访问errorMessage

修改Run函数为bool Run(out string errorMessage)的形式，不通过errorMessage共享数据，使其支持并发操作。

这两种方式都是有效的，但都有一些不足：加锁时获取和释放互斥体有一个不小的开销，当共享的数据较多时修改Run函数会导致Run函数变得很难看，并且可能会由于改动较大而导致大规模重构。

针对上述两种方式的不足，人们提出了线程专有存储的解决方案，使用ThreadLocal类的解决方案如下：

    ThreadLocal<string> errorMessage = new ThreadLocal<string> ();

    void Process()
    {
        bool ret = Run();
        if (!ret && needDebug)
        {
            Console.WriteLine(errorMessage);
        }
    }

    bool Run()
    {
        try
        {
            …- do something
            return true;
        }
        catch (Exception e)
        {
            errorMessage.Value=e.Message;
            return false;
        }
    }

ThreadLocal类在每个线程下都分配一个独立实例副本，每个线程都只访问到自己的实例，不会影响其它线程，从而解决读脏数据的问题。

ThreadLocal类也不是什么新概念，在C++、Java等语言的线程库中都有相关实现，一些语言编译器实现（如IBM XL FORTRAN）中甚至在语言的层次提供了直接的支持。其实实现的思路很简单：在ThreadLocal类中有一个哈希表，根据线程ID为key用于存储每一个线程的变量的副本。由于现在没啥相关资料，并且也是beta版的，我也懒得对.Net中的具体实现和性能进一步分析。

和上面的两种方式相比，线程专有存储有如下好处：

  • 效率：线程专有存储可实现成无需对线程专有数据进行锁定。例如，通过将errno放入线程专有存储中，每个线程都可以可靠地设置和测试该线程中的方法的完成状态，而无需使用复杂的同步协议。这排除了线程中共享数据的锁定开销，比起获取和释放互斥体要更为迅捷。
  • 易于使用：对于应用程序员来说，线程专有存储使用起来很简单，因为系统开发者可以通过数据抽象或宏来使线程专有存储的使用在源码级完全透明化。

但也存在如下缺点：

  • 它鼓励了（线程安全的）全局变量的使用：许多应用不要求多个线程通过公用访问点来访问线程专有的数据。如果是这样，数据的存储应使只有拥有该数据的线程可对它进行访问。
  • 它隐藏了系统的结构：线程专有存储的使用隐藏了应用中的对象之间的关系，可能会导致应用更难被理解。

适用性

应用有以下特性时可使用线程专有存储：

  • 应用最初的编写假定了单线程控制，并正在被移植到多线程环境，而又不能改变现有API
  • 应用含有多个占先式线程控制，可以任意的调度顺序并发执行；
  • 每个线程控制调用一系列方法，这些方法共享只对该线程来说是公用的数据；
  • 在每个线程中被对象共享的数据必须通过一个全局可见的访问点来访问；
  • 访问点"逻辑地"与其他线程共享，但在"物理上" 对于每个线程却是唯一的；
  • 数据在方法间隐式地传递，而不是经由参数显式地传递。

理解上面描述的特性对于使用（或不使用）线程专有存储模式来说是至关紧要的。例如，UNIX errno变量是一个数据例子：（1）逻辑上全局，但是物理上线程专有，以及（2）在方法间隐式地传递。

当应用有以下特性时，不要使用线程专有存储模式：

  • 多个线程为单个任务协同工作，该任务需要并发访问共享数据。
    例如，多线程应用可以对在内存中的数据库并发地进行读写。在这样的情况下，线程必须共享不是线程专有的记录和表。如果使用线程专有存储来存储此数据库，线程就不能共享这些数据。因而，对数据库记录的访问必须通过同步原语（例如，互斥体）来控制，以使线程能在共享数据上协作。
  • 维护物理和逻辑上都分离的数据要更为直观和高效。
    例如，通过将数据作为参数显式地传递给所有方法，有可能使线程访问仅在每个线程中可见的数据。在这样的情况下，线程专有存储模式有可能是不必要的。

到此这篇关于C#线程绑定ThreadLocal类的文章就介绍到这了。希望对大家的学习有所帮助，也希望大家多多支持我们。

赞 (0)

相关推荐

  • C#多线程异步执行和跨线程访问控件Helper

    一.工具类代码 public class TaskHelper { #region 多线程操作 /// <summary> /// 功能描述:多线程执行方法,方法无参数,无返回值 /// </summary> /// <param name="func">方法,如果方法中调用了控件,请使用 ThreadInvokerControl(() => { 您的操作})进行包括</param> /// <param name="

  • C#多线程之线程池ThreadPool详解

    一.ThreadPool概述 提供一个线程池,该线程池可用于执行任务.发送工作项.处理异步 I/O.代表其他线程等待以及处理计时器. 创建线程需要时间.如果有不同的小任务要完成,就可以事先创建许多线程/在应完成这些任务时发出请求.不需要自己创建这样一个列表.该列表由ThreadPool类托管. 这个类会在需要时增减池中线程的线程数,直到最大的线程数.池中的最大线程数是可配置的.在双核CPU中,默认设置为1023 个工作线程和1000个I/O线程.也可以指定在创建线程池时应立即启动的最小线程数,以

  • C#多线程之线程池(ThreadPool)

    C#多线程之线程池(ThreadPool)

    一.简介 前面介绍了平时用到的大多数的多线程的例子,但在实际开发中使用的线程往往是大量的和更为复杂的,这时,每次都创建线程.启动线程.从性能上来讲,这样做并不理想(因为每使用一个线程就要创建一个,需要占用系统开销):从操作上来讲,每次都要启动,比较麻烦.为此引入的线程池的概念. 好处: 1.减少在创建和销毁线程上所花的时间以及系统资源的开销 2.如不使用线程池,有可能造成系统创建大量线程而导致消耗完系统内存以及”过度切换”. 在什么情况下使用线程池? 1.单个任务处理的时间比较短 2.需要处理的

  • C#多线程之线程通讯(AutoResetEvent)

    C#多线程之线程通讯(AutoResetEvent)

    一.简介 我们在线程编程的时候往往会涉及到线程的通信,通过信号的接受来进行线程是否阻塞的操作.AutoResetEvent 允许线程通过发信号互相通信.通常,此通信涉及线程需要独占访问的资源.具体方法和扩展方法请详见AutoResetEvent类,最常用方法中就有Set()和WaitOne().线程通过调用 AutoResetEvent 上的 WaitOne 来等待信号.如果 AutoResetEvent 处于非终止状态,则该线程阻塞,并等待当前控制资源的线程通过调用 Set 发出资源可用的信号

  • C#中异步和多线程的区别介绍

    一.区别和联系 异步和多线程有什么区别?其实,异步是目的,而多线程是实现这个目的的方法.异步是说,A发起一个操作后(一般都是比较耗时的操作,如果不耗时的操作就没有必要异步了),可以继续自顾自的处理它自己的事儿,不用干等着这个耗时操作返回..Net中的这种异步编程模型,就简化了多线程编程,我们甚至都不用去关心Thread类,就可以做一个异步操作出来. 异步有的时候用普通的线程,有的时候用系统的异步调用功能.有一些IO操作也是异步的,但是未必需要一个线程来运行.例如:硬件是有DMA功能的,在调用DM

  • C#多线程之线程锁

    目录 一.Mutex类 二.Mutex的用途 三.Semaphore信号量 1.简介 2.初始化 3.WaitOne()和Release() 四.Monitor类 典型的生产者与消费者实例 五.Lock 六.InterLocked(相当于lock,对整数) 1.Interlocked类主要方法 2.实例 一.Mutex类 “mutex”是术语“互相排斥(mutually exclusive)”的简写形式,也就是互斥量.互斥量跟临界区中提到的Monitor很相似,只有拥有互斥对象的线程才具有访问资

  • 浅析C#中的AsnycLocal与ThreadLocal

    AsnyncLocal与ThreadLocal都是存储线程上下文的变量,但是,在实际使用过程中两者又有区别主要的表现在: AsyncLocal变量可以在父子线程中传递,创建子线程时父线程会将自己的AsyncLocal类型的上下文变量赋值到子线程中,但是,当子线程改变线程上下文中AsnycLocal变量值后,父线程不会同步改变.也就是说AsnycLocal变量只会影响他的子线程,不会影响他的父级线程. TreadLocal只是当前线程的上下文变量,不能在父子线程间同步. using System;

  • C#多线程之线程绑定ThreadLocal类

    在.Net 4.0的Thread里,新增了线程局部变量(ThreadLocal)类,可以很方便的实现线程专有存储. 应用场景 线程专有存储应被用于这样的多线程应用:它们经常访问那些逻辑上是全局的.而物理上是专有于每个线程的对象.首先我们看如下这样一个例子 string errorMessage; void Process() { bool ret = Run(); if (!ret && needDebug) { Console.WriteLine(errorMessage); } } b

  • 简单分析Java线程编程中ThreadLocal类的使用

    一.概述   ThreadLocal是什么呢?其实ThreadLocal并非是一个线程的本地实现版本,它并不是一个Thread,而是threadlocalvariable(线程局部变量).也许把它命名为ThreadLocalVar更加合适.线程局部变量(ThreadLocal)其实的功用非常简单,就是为每一个使用该变量的线程都提供一个变量值的副本,是Java中一种较为特殊的线程绑定机制,是每一个线程都可以独立地改变自己的副本,而不会和其它线程的副本冲突.   从线程的角度看,每个线程都保持一个对

  • java多线程编程之使用thread类创建线程

    在Java中创建线程有两种方法:使用Thread类和使用Runnable接口.在使用Runnable接口时需要建立一个Thread实例.因此,无论是通过Thread类还是Runnable接口建立线程,都必须建立Thread类或它的子类的实例.Thread类的构造方法被重载了八次,构造方法如下: 复制代码 代码如下: public Thread( );public Thread(Runnable target);public Thread(String name);public Thread(Ru

  • java多线程中线程封闭详解

    线程封闭的概念 访问共享变量时,通常要使用同步,所以避免使用同步的方法就是减少共享数据的使用,这种技术就是线程封闭. 实现线程封闭的方法 1:ad-hoc线程封闭 这是完全靠实现者控制的线程封闭,他的线程封闭完全靠实现者实现.也是最糟糕的一种线程封闭.所以我们直接把他忽略掉吧. 2:栈封闭 栈封闭是我们编程当中遇到的最多的线程封闭.什么是栈封闭呢?简单的说就是局部变量.多个线程访问一个方法,此方法中的局部变量都会被拷贝一分儿到线程栈中.所以局部变量是不被多个线程所共享的,也就不会出现并发问题.所

  • 实例讲解Java并发编程之ThreadLocal类

    ThreadLocal类可以理解为ThreadLocalVariable(线程局部变量),提供了get与set等访问接口或方法,这些方法为每个使用该变量的线程都存有一份独立的副本,因此get总是返回当前执行线程在调用set时设置的最新值.可以将ThreadLocal<T>视为 包含了Map<Thread,T>对象,保存了特定于该线程的值. 概括起来说,对于多线程资源共享的问题,同步机制采用了"以时间换空间"的方式,而ThreadLocal采用了"以空间

  • java多线程之线程同步七种方式代码示例

    为何要使用同步?  java允许多线程并发控制,当多个线程同时操作一个可共享的资源变量时(如数据的增删改查),     将会导致数据不准确,相互之间产生冲突,因此加入同步锁以避免在该线程没有完成操作之前,被其他线程的调用,     从而保证了该变量的唯一性和准确性. 1.同步方法  即有synchronized关键字修饰的方法.     由于java的每个对象都有一个内置锁,当用此关键字修饰方法时,     内置锁会保护整个方法.在调用该方法前,需要获得内置锁,否则就处于阻塞状态.     代码

  • Java8新特性之线程安全日期类

    Java8新特性之线程安全日期类

    LocalDateTime Java8新特性之一,新增日期类. 在项目开发过程中经常遇到时间处理,但是你真的用对了吗,理解阿里巴巴开发手册中禁用static修饰SimpleDateFormat吗 通过阅读本篇文章你将了解到: 为什么需要LocalDate.LocalTime.LocalDateTime[java8新提供的类] Java8新的时间API的使用方式,包括创建.格式化.解析.计算.修改 可以使用Instant代替 Date,LocalDateTime代替 Calendar,DateTi

  • Java ThreadLocal类使用详解

    Java ThreadLocal类使用详解

    目录 前言 快速开始 ThreadLocal的原理 ThreadLocal相关类图 set get remove 小结 ThreadLocal内存泄露 为什么会出现内存泄漏? 为什么使用弱引用? 解决方法 总结 前言 这几天看<Java并发编程之美>的时候又遇到了ThradLocal这个类,不得不说,这个类在平时很多场景都遇得到,所以对其进行一个系统性的学习,然后再输出成这篇博客. 那么,什么是ThreadLocal呢? 我们都知道,多线程访问同一个共享变量很容易出现并发问题,特别是当多个线程

  • Java多线程之线程通信生产者消费者模式及等待唤醒机制代码详解

    前言 前面的例子都是多个线程在做相同的操作,比如4个线程都对共享数据做tickets–操作.大多情况下,程序中需要不同的线程做不同的事,比如一个线程对共享变量做tickets++操作,另一个线程对共享变量做tickets–操作,这就是大名鼎鼎的生产者和消费者模式. 正文 一,生产者-消费者模式也是多线程 生产者和消费者模式也是多线程的范例.所以其编程需要遵循多线程的规矩. 首先,既然是多线程,就必然要使用同步.上回说到,synchronized关键字在修饰函数的时候,使用的是"this"

  • Java 中ThreadLocal类详解

    ThreadLocal类,代表一个线程局部变量,通过把数据放在ThreadLocal中,可以让每个线程创建一个该变量的副本.也可以看成是线程同步的另一种方式吧,通过为每个线程创建一个变量的线程本地副本,从而避免并发线程同时读写同一个变量资源时的冲突. 示例如下: import java.util.Random; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import ja

随机推荐