muduo网络库学习之ThreadLocal<T> 类、ThreadLocalSingleton<T>类封装知识点

一、ThreadLocal<T>类

1、在单线程程序中,我们经常要用到"全局变量"以实现多个函数间共享数据。

2、在多线程环境下,由于数据空间是共享的,因此全局变量也为所有线程所共有。

3、但有时应用程序设计中有必要提供线程私有的全局变量,仅在某个线程中有效,但却可以跨多个函数访问。

4、POSIX线程库通过维护一定的数据结构来解决这个问题,这些数据称为(Thread-specific Data,或 TSD)。

5、线程特定数据也称为线程本地存储TLS(Thread-local storage)

6、对于POD类型的线程本地存储,可以用__thread关键字

pthread_key_create、pthread_key_delete、pthread_getspecific、pthread_setspecific,更多信息请看这里

template<typename T> class ThreadLocal : boost::noncopyable

一旦某个线程创建了一个key,比如key[1],那么其他线程也有自己的key[1],它们通过各自的key[1]访问到的实际数据(堆上内存分配的空间)是不同的,pthread_key_delete 只是删除key,实际数据空间的释放需要在pthread_key_create 中注册一个回调函数destructor去delete T*。

ThreadLocal()   {

    pthread_key_create(&pkey_, &ThreadLocal::destructor);

  }

当某个线程运行结束,这个线程对应的实际数据T也没有存在的价值,会调用destructor,从而delete T*;

也就是说如果有两个线程,那么destructor会执行两次,因为实际数据T在每个线程中各有一份。

key 的删除在~ThreadLocal()函数内:

~ThreadLocal()  {

    pthread_key_delete(pkey_);

 }

测试代码:

SingletonThreadLocal_test.cc:

#include <muduo/base/Singleton.h>
#include <muduo/base/CurrentThread.h>
#include <muduo/base/ThreadLocal.h>
#include <muduo/base/Thread.h>

#include <boost/bind.hpp>
#include <boost/noncopyable.hpp>
#include <stdio.h>

class Test : boost::noncopyable
{
public:
    Test()
    {
        printf("tid=%d, constructing %p\n", muduo::CurrentThread::tid(), this);
    }

    ~Test()
    {
        printf("tid=%d, destructing %p %s\n", muduo::CurrentThread::tid(), this, name_.c_str());
    }

    const std::string &name() const
    {
        return name_;
    }
    void setName(const std::string &n)
    {
        name_ = n;
    }

private:
    std::string name_;
};

#define STL muduo::Singleton<muduo::ThreadLocal<Test> >::instance().value()

void print()
{
    printf("tid=%d, %p name=%s\n",
           muduo::CurrentThread::tid(),
           &STL,
           STL.name().c_str());
}

void threadFunc(const char *changeTo)
{
    print();
    STL.setName(changeTo);
    sleep(1);
    print();
}

int main()
{
    STL.setName("main one");
    muduo::Thread t1(boost::bind(threadFunc, "thread1"));
    muduo::Thread t2(boost::bind(threadFunc, "thread2"));
    t1.start();
    t2.start();
    t1.join();
    print();
    t2.join();
    pthread_exit(0);
}

muduo::Singleton<muduo::ThreadLocal<Test> >::instance() 保证不同线程调用返回的都是同一个ThreadLocal<Test> 对象,

而不同线程调用ThreadLocal<Test>.value(); 返回的是不同的Test对象,即在不同线程中各有一份实际数据。

输出如下:

// 红色为不同Test对象的地址

simba@ubuntu:~/Documents/build/debug/bin$ ./singletonthreadlocal_test  tid=2894, constructing 0x8507038 //main thread tid=2896, constructing 0xb6200468 // thread2 tid=2896, 0xb6200468 name= tid=2895, constructing 0xb6300468 // thread1 tid=2895, 0xb6300468 name= tid=2896, 0xb6200468 name=thread2 tid=2896, destructing 0xb6200468 thread2 tid=2895, 0xb6300468 name=thread1 tid=2895, destructing 0xb6300468 thread1 tid=2894, 0x8507038 name=main one tid=2894, destructing 0x8507038 main one simba@ubuntu:~/Documents/build/debug/bin$ 

二、ThreadLocalSingleton<T>类

template<typename T>

class ThreadLocalSingleton : boost::noncopyable

{

     class Deleter { };

};

每个线程都有一个单例对象T,即每个线程都有一个T*(__thread修饰,指针是POD类型数据),每个线程都有各自的特定数据(用TSD实现),t_value_ 即指向实际数据T的指针。

其中instance() 的实现与Singleton 类的实现不同,因为这里是每个线程各有一个单例对象T,而不是所有线程共享一个。

deleter_ 是静态数据成员,为所有线程所共享;t_value_ 虽然也是静态数据成员,但加了__thread 修饰符,故每一个线程都会有一份。Deleter类是用来实现当某个线程执行完毕,执行注册的destructor函数,进而delete t_value_ 。key 的删除在~Deleter() 中

~Deleter() {       pthread_key_delete(pkey_); }

测试代码:

ThreadLocalSingleton_test.cc:

#include <muduo/base/ThreadLocalSingleton.h>
#include <muduo/base/CurrentThread.h>
#include <muduo/base/Thread.h>

#include <boost/bind.hpp>
#include <boost/noncopyable.hpp>
#include <stdio.h>

class Test : boost::noncopyable
{
public:
    Test()
    {
        printf("tid=%d, constructing %p\n", muduo::CurrentThread::tid(), this);
    }

    ~Test()
    {
        printf("tid=%d, destructing %p %s\n", muduo::CurrentThread::tid(), this, name_.c_str());
    }

    const std::string &name() const
    {
        return name_;
    }
    void setName(const std::string &n)
    {
        name_ = n;
    }

private:
    std::string name_;
};

void threadFunc(const char *changeTo)
{
    printf("tid=%d, %p name=%s\n",
           muduo::CurrentThread::tid(),
           &muduo::ThreadLocalSingleton<Test>::instance(),
           muduo::ThreadLocalSingleton<Test>::instance().name().c_str());
    muduo::ThreadLocalSingleton<Test>::instance().setName(changeTo);
    sleep(2);  //如果没有sleep,可能thread2在thread1退出后才运行,%p可能是原来的值
    printf("tid=%d, %p name=%s\n",
           muduo::CurrentThread::tid(),
           &muduo::ThreadLocalSingleton<Test>::instance(),
           muduo::ThreadLocalSingleton<Test>::instance().name().c_str());

    // no need to manually delete it
    // muduo::ThreadLocalSingleton<Test>::destroy();
}

int main()
{
    muduo::ThreadLocalSingleton<Test>::instance().setName("main one");
    muduo::Thread t1(boost::bind(threadFunc, "thread1"));
    muduo::Thread t2(boost::bind(threadFunc, "thread2"));
    t1.start();
    t2.start();
    t1.join();
    printf("tid=%d, %p name=%s\n",
           muduo::CurrentThread::tid(),
           &muduo::ThreadLocalSingleton<Test>::instance(),
           muduo::ThreadLocalSingleton<Test>::instance().name().c_str());
    t2.join();

    pthread_exit(0);
}

输出如下:

// 红色为不同Test 对象的地址

simba@ubuntu:~/Documents/build/debug/bin$ ./threadlocalsingleton_test  tid=3341, constructing 0x8a22028  // main thread tid=3343, constructing 0xb6200468  // thread 2 tid=3343, 0xb6200468 name= tid=3342, constructing 0xb6000468  // thread 1 tid=3342, 0xb6000468 name= tid=3343, 0xb6200468 name=thread2 tid=3343, destructing 0xb6200468 thread2 tid=3342, 0xb6000468 name=thread1 tid=3342, destructing 0xb6000468 thread1 tid=3341, 0x8a22028 name=main one tid=3341, destructing 0x8a22028 main one

参考:

muduo manual.pdf

《linux 多线程服务器编程:使用muduo c++网络库》

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏静晴轩

lua表排序

Lua作为一种很强大且轻量级脚本语言的存在,对于掌握其几乎无所不能的Table(其实就是一个Key Value的数据结构,它很像Javascript中的Obje...

40111
来自专栏Java编程技术

ClassLoader解惑

一个Java程序要想运行起来,首先需要经过编译生成 .class文件,然后创建一个运行环境(jvm)来加载字节码文件到内存运行,而.class 文件是怎样被加载...

961
来自专栏君赏技术博客

Object-C中的黑魔法

在Swift中存在Option类型,也就是使用?和!声明的变量。但是OC里面没有这个特征,因为在XCODE6.3之后出现新的关键词定义用于OC转SWIFT时候可...

1311
来自专栏Java Edge

Netty 源码深度解析(八) - 解码

就像很多标准的架构模式都被各种专用框架所支持一样,常见的数据处理模式往往也是目标实现的很好的候选对象,它可以节省开发人员大量的时间和精力。

921
来自专栏desperate633

[编程题] 双核处理分析代码

一种双核CPU的两个核能够同时的处理任务,现在有n个已知数据量的任务需要交给CPU处理,假设已知CPU的每个核1秒可以处理1kb,每个核同时只能处理一项任务。n...

714
来自专栏跟着阿笨一起玩NET

开源实体映射框架EmitMapper介绍

EmitMapper是一个开源实体映射框架,地址:http://emitmapper.codeplex.com/。

1112
来自专栏Android 研究

Retrofit解析8之核心解析——ServiceMethod及注解1

上篇文章已经介绍了Retrofit里面的大多数类,今天就重点介绍ServiceMethod,本片文章主要内容如下:

1674
来自专栏Spark学习技巧

Flink DataSet编程指南-demo演示及注意事项

Flink中的DataStream程序是对数据流进行转换的常规程序(例如,过滤,更新状态,定义窗口,聚合)。数据流的最初的源可以从各种来源(例如,消息队列,套接...

2.7K12
来自专栏hbbliyong

HTML5 Blob与ArrayBuffer、TypeArray和字符串String之间转换

1.将String字符串转换成Blob对象 //将字符串 转换成 Blob 对象 var blob = new Blob(["Hello World!"], {...

3765
来自专栏iOS技术杂谈

iOS runtime探究(三): 从runtime开始理解OC的属性property你要知道的runtime都在这里

你要知道的runtime都在这里 转载请注明出处 https://cloud.tencent.com/developer/user/1605429 本文主要讲解...

2879

扫码关注云+社区