线程局部变量的使用与多线程开发
创始人
2024-06-07 19:10:18
0

多线程,现在多核时代来临之际,多线程编程已经成为了时髦语。有专门应运而生的Erlang,以及以Actor著称的Scala语言。下面介绍线程局部变量的使用,对于学习使用多线程会有一些帮助。

一、概述

现在多核时代多线程开发越来越重要了,多线程相比于多进程有诸多优势(当然也有诸多劣势)。在早期C的库中,有许多函数是线程不安全的,因为内部用到了静态变量,比如:char *strtok(char *s, const char *delim); 该函数内部就有一个静态指针,如果多个线程同时调用此函数时,可能就会出现奇怪的结果,当然也不是我们所想要的,现在LINUX对此函数功能有一个线程安全版本的接口:char *strtok_r(char *s, const char *delim, char **ptrptr),这就避免了多个线程同时访问的冲突问题。其实,如果保持 strtok()/2 接口不变,同时还要保证线程安全,还有一个解决办法,那就是采用线程局部变量。

使用线程局部变量有两种使用方式,一个稍微麻烦些,一个比较简单,下面一一做个介绍(以LINUX为例)

二、线程局部变量的使用

比较麻烦些的使用方法用到的函数主要有三个:pthread_once(pthread_once_t*, void (*init_routine)(void)), pthread_key_create()/2, pthread_setspecific()/2, pthread_getspecific()/1,其中 pthread_once 可以保证在整个进程空间init_routine函数仅被调用一次(它解决了多线程环境中使得互斥量和初始化代码都仅被初始化一次的问题);pthread_key_create 的参数之一指一个析构函数指针,当某个线程终止时该析构函数将被调用,并用对于一个进程内的给定键,该函数只能被调用一次;pthread_sespecific 和 pthread_getspecific 用来存放和获取与一个键关联的值。例子如下:

  1. pthread_key_t key;  
  2. pthread_once_t once = PTHREAD_ONCE_INIT;  
  3.  
  4. static void destructor(void *ptr)  
  5. {  
  6. free(ptr);  
  7. }  
  8.  
  9. void init_once(void)  
  10. {  
  11. pthread_key_create(&key, destructor);  
  12. }  
  13.  
  14. static void *get_buf(void)  
  15. {  
  16. pthread_once(&once, init_once);  
  17.  
  18. if ((ptr = pthread_getspecific(key)) == NULL) {  
  19. ptr = malloc(1024);  
  20. pthread_setspecific(key, ptr);  
  21. }  
  22. return (ptr);  
  23. }  
  24.  
  25. static void *thread_fn(void *arg)  
  26. {  
  27. char *ptr = (char*) get_buf();  
  28.  
  29. sprintf(ptr, "hello world");  
  30. printf(">>%s\n", ptr);  
  31. return (NULL);  
  32. }  
  33.  
  34. void test(void)  
  35. {  
  36. int   i, n = 10;  
  37. pthread_t tids[10];  
  38.  
  39. for (i = 0; i < n; i++) {  
  40. pthread_create(&tids[i], NULL, thread_fn, NULL);  
  41. }  
  42.  
  43. for (i = 0; i < n; i++) {  
  44. pthread_join(&tids[i], NULL);  
  45. }  
  46. }  
  47.    

另外,还有一个更加简单使用线程局部变量的方法:__thread 修饰符, (在WIN32平台下需要用: __declspec(thread) 修饰符,WIN32的东东总得要多写几笔,呵呵),于是上述代码可以修改如下:

  1. static void *get_buf(void)  
  2. {  
  3. static __thread void *ptr = malloc(1024);  
  4. return (ptr);  
  5. }  
  6.  
  7. static void *thread_fn(void *arg)  
  8. {  
  9. char *ptr = (char*) get_buf();  
  10.  
  11. sprintf(ptr, "hello world");  
  12. printf(">>%s\n", ptr);  
  13. return (NULL);  
  14. }  
  15.  
  16. void test(void)  
  17. {  
  18. int   i, n = 10;  
  19. pthread_t tids[10];  
  20.  
  21. for (i = 0; i < n; i++) {  
  22. pthread_create(&tids[i], NULL, thread_fn, NULL);  
  23. }  
  24.  
  25. for (i = 0; i < n; i++) {  
  26. pthread_join(&tids[i], NULL);  
  27. }  
  28. }  
  29.    

看到没有,这段代码比前面一个简单许多,但却有一个问题,它存在内存泄露问题,因为当线程退出时各个线程分配的动态内存(ptr = malloc(1024)) 并没有被释放。

三、用ACL线程接口操作线程局部变量

为了解决上述问题,ACL库中实现了线程局部变量的简单释放功能:acl_pthread_atexit_add(void *arg, void (*free_callback)(void*)),修改上述代码如下:

  1. static void free_fn(void *ptr)  
  2. {  
  3. free(ptr);  
  4. }  
  5.  
  6. static void *get_buf(void)  
  7. {  
  8. static __thread void *ptr = malloc(1024);  
  9.  
  10. acl_pthread_atexit_add(ptr, free_fn);  
  11. return (ptr);  
  12. }  
  13.  
  14. static void *thread_fn(void *arg)  
  15. {  
  16. char *ptr = (char*) get_buf();  
  17.  
  18. sprintf(ptr, "hello world");  
  19. printf(">>%s\n", ptr);  
  20. return (NULL);  
  21. }  
  22.  
  23. void test(void)  
  24. {  
  25. int   i, n = 10;  
  26. pthread_t tids[10];  
  27.  
  28. for (i = 0; i < n; i++) {  
  29. acl_pthread_create(&tids[i], NULL, thread_fn, NULL);  
  30. }  
  31.  
  32. for (i = 0; i < n; i++) {  
  33. acl_pthread_join(&tids[i], NULL);  
  34. }  
  35. }  
  36.    

ok, 一切问题得到解决。细心的读者会发现 pthread_create, pthread_join 前面都加了前缀: acl_, 这是因为 ACL库对线程库进行了封装,以适应不同平台下(UNIX、WIN32)下的使用,这个例子是跨平台的,WIN32下同样可用。

【编辑推荐】

  1. 多线程的批量线程同步解决方案
  2. 使用Java多线程实现任务分发
  3. 细说Singleton模式:创建、多线程与销毁
  4. Java多线程编程实战精要
  5. 用Java多线程实现无阻塞读取远程文件

相关内容

热门资讯

如何允许远程连接到MySQL数... [[277004]]【51CTO.com快译】默认情况下,MySQL服务器仅侦听来自localhos...
如何利用交换机和端口设置来管理... 在网络管理中,总是有些人让管理员头疼。下面我们就将介绍一下一个网管员利用交换机以及端口设置等来进行D...
施耐德电气数据中心整体解决方案... 近日,全球能效管理专家施耐德电气正式启动大型体验活动“能效中国行——2012卡车巡展”,作为该活动的...
20个非常棒的扁平设计免费资源 Apple设备的平面图标PSD免费平板UI 平板UI套件24平图标Freen平板UI套件PSD径向平...
德国电信门户网站可实时显示全球... 德国电信周三推出一个门户网站,直观地实时提供其安装在全球各地的传感器网络检测到的网络攻击状况。该网站...
为啥国人偏爱 Mybatis,... 关于 SQL 和 ORM 的争论,永远都不会终止,我也一直在思考这个问题。昨天又跟群里的小伙伴进行...
《非诚勿扰》红人闫凤娇被曝厕所... 【51CTO.com 综合消息360安全专家提醒说,“闫凤娇”、“非诚勿扰”已经被黑客盯上成为了“木...
2012年第四季度互联网状况报... [[71653]]  北京时间4月25日消息,据国外媒体报道,全球知名的云平台公司Akamai Te...