Pthread

转自：http://blog.chinaunix.net/uid-21084809-id-2215376.html

Outline 

- 1.线程特点

- 2.pthread创建

- 3.pthread终止

        - 4.mutex互斥量使用框架

        - 5.cond条件变量

        - 6.综合实例

================================================================================================
1. 线程特点
线程拥有自己独立的栈、调度优先级和策略、信号屏蔽字（创建时继承）、errno变量以及线程私有数据。进程的其他地址空间均被所有线程所共享，因此线程可以访问程序的全局变量和堆中分配的数据，并通过同步机制保证对数据访问的一致性。

2. pthread创建
pthread有一个线程ID，类型为pthread_t，在使用printf打印时，应转换为u类型。
pthread_equal可用于比较两个id是否相等；pthread_self用于获取当前线程的ID。
pthread_create用于创建新的线程，可以给线程传入一个void *类型的参数，例如一个结构体指针或者一个数值。
系统并不能保证哪个线程会现运行：新创建的线程还是调用线程。

3. pthread终止
a) 从线程函数中返回
b) 被同一进程中的其他线程取消
c) 线程调用pthread_exit
注意，线程的返回值需要转换为void *类型。

pthread_exit(void *ret)
pthread_join(pthread_t id, void **ret)

ret均可设置为NULL

4.  mutex 互斥量使用框架
pthread_mutex_t lock;
pthread_mutex_init 或者 PTHREAD_MUTEX_INITIALIZER（仅可用在静态变量）
pthread_mutex_lock / pthread_mutex_unlock / pthread_mutex_trylock
pthread_mutex_destroy

5. cond 条件变量
pthread_cond_t qready;
pthread_mutex_t qlock;
pthread_mutex_init 或者 PTHREAD_MUTEX_INITIALIZER
pthread_cond_init 或者 PTHREAD_COND_INITIALIZER
pthread_mutex_lock(&qlock...)
pthread_cond_wait(&qready, &qlock...) / pthread_cond_timewait
pthread_mutex_unlock(&qlock)
pthread_cond_destroy

//唤醒条件变量
pthread_cond_signal
pthread_cond_broadcast

条件变量是pthread中比较难以理解的一点，主要会产生以下疑惑：
Q1. 假如在调用pthread_{cond_wait | cond_timedwait}之前就调用pthread_cond_{signal | broadcast}会发生什么？

Q2. pthread_cond_{cond_wait | cond_timewait}为什么需要一个已经锁住的mutex作为变量？

Q3. pthread_cond_{signal | broadcast}使用之前必须获取wait中对应的mutex吗？

Q4. 假如pthread_cond_{signal | broadcast}必须获取mutex，那么下列两种形式，哪种正确？为什么？

1)
lock(lock_for_X);
change(X);
 unlock(lock_for_X);
 pthread_cond_{signal | broadcast};

2)
lock(lock_for_X);
change(X);
 pthread_cond_{signal | broadcast};
 unlock(lock_for_X);

----思考-------思考-------思考-------思考------思考-------思考------思考------思考-------思考-------

A1: 什么都不会发生，也不会出错，仅仅造成这次发送的signal丢失。

A2: 一般场景如下，我们需要检查某个条件是否满足（如队列X是否为空、布尔Y是否为真），假如没有条件变量，我们唯一的选择是

  1. while (1) {
  2.   lock(lock_for_X);

  4.   if (X is not empty) {
  5.     unlock(lock_for_X);
  6.     break;
  7.   } else { //X is empty, loop continues
  8.     unlock(lock_for_X);
  9.     sleep(10);
  10.   }
  11. }
  12. //X is not empty, loop ends
  13. process(X);

明显这种轮询的方式非常耗费CPU时间，这时候我们很容易的想到，如果有一种机制，可以异步通知我们队列的状态发生了变化，那么我们便无须再轮询，只要等到通知到来时再检查条件是否满足即可，其他时间则将程序休眠，因此现在代码变成这样：

  1. while (1) {
  2.   lock(lock_for_X);
  3.   if (X is not empty) { 
  4.     unlock(lock_for_X);
  5.     break;
  6.   } else {
  7.     unlock(lock_for_X); //must called before my_wait(), otherwise no one can acquire the lock and make change to X
  8.     -------------------------------------->窗口，由于已经解锁，其他程序可能改变X，并且试图唤醒mywait，但在一个繁忙的系统中，可能此时my_还没被调用！
  9.     my_wait(); //go to sleep and wait for the notification
  10.   }
  11. }

my_wait是一个假想的函数，作用如注释所示。
不难发现，这样做以后，我们无须再轮询了，只需要等待my_wait()被唤醒以后检查条件是否满足。
但是请注意，正如图中所示，存在1个时间窗口。若其他程序在这个窗口中试图唤醒my_wait，由于此时my_wait还没有被调用，那么这个信号将丢失，造成my_wait一直阻塞。解决的办法就是，要将unlock和my_wait合并成一个原子操作，这样就不会被其他程序插入执行。我想到这里，你应该已经明白了，这个原子操作的函数就是pthread_cond_{signal | broadcast}.

A3: 是的。
详见：http://stackoverflow.com/questions/4544234/calling-pthread-cond-signal-without-locking-mutex

A4: 对于1)，在不同的操作系统中，可能会造成不确定的调度结果（可能会造成调度优先级反转）；对于2）可以保证无论在何种操作系统中都将获得预期的调度顺序。

设想一个场景：有两个消费者线程A和B，我们设定A的优先级比B高，A正在等待条件变量被出发，即已经调用了pthread_wait，并且处于阻塞状态：

  1. lock(lock_for_X);
  2. while (X is empty) {
  3.   pthread_cond_wait(&qready, &lock_for_X);
  4. }
  5. unlock(lock_for_X);

B中没有调用pthread_wait，而是做类似如下的处理：

  1. while(1) { 
  2.   lock(lock_for_X);
  3.   dequeue(X);
  4.   unlock(lock_for_X);
  5. }
另一个线程C，为生产者，采用1)方案，则代码如下，先unlock，再发出signal：

lock(lock_for_X);
change(X);
 unlock(lock_for_X);
 pthread_cond_{signal | broadcast};

当发出unlock以后，发送signal之前，此时消费者B已经满足了运行条件，而消费者A虽然优先级比B高，但是由于其运行条件还需要signal，所以不具备立刻运行的条件，此时就看操作系统如何实现调度算法了。有些操作系统，可能会因为A不具备立刻运行条件，即使它的优先级比B高，此时还是让B线程先运行，那么，后续将分成两种情况：

(a) B获得了lock，但是还没有将X队列中的刚刚加入的条目移除，此时C调用了signal，A接收到了signal，由于A的优先级高，那么A抢占B，A从函数pthread_cond_wait返回之前需要再次将lock上锁，但是A抢占后发现，lock被人锁住了（还没有被B释放），只好再次休眠，等待锁被释放，结果B又被唤醒，也可能因此造成A和B的死锁，这个具体要看操作系统的调度算法。

(b) B获得了lock，并且执行了dequeue，然后释放了锁。此时C调用了signal，A接收到了signal，由于A的优先级高，那么A抢占B，A这次顺利的获取了锁得以从pthread_cond_wait中返回，但是在检查条件时，却发现队列是空的，于是乎再次进入pthread_cond_wait休眠。结果A又无法被执行，A可能由此进入饥饿状态。

但是如果C采用2)方案：

lock(lock_for_X);
change(X);
 pthread_cond_{signal | broadcast};
 unlock(lock_for_X);
在unlock以后，A、B都具备了立即运行的条件，由于A比B的优先级高，因此操作系统必定会先调度A执行，就避免了前面一种不确定的调度结果。

主要参考：http://groups.google.com/group/comp.programming.threads/msg/a3721a2fc9b21c64?hl=ky

6. 综合实例
  1. /*
  2.  * =====================================================================================
  3.  *
  4.  * Filename: pthread.c
  5.  *
  6.  * Description: 
  7.  *
  8.  * Version: 1.0
  9.  * Created: 08/17/11 11:06:35
  10.  * Revision: none
  11.  * Compiler: gcc
  12.  *
  13.  * Author: YOUR NAME (), 
  14.  * Company: 
  15.  *
  16.  * =====================================================================================
  17.  */
  18. #include <stdio.h>
  19. #include <pthread.h>
  20. #include <error.h>
  21. #include <stdlib.h>
  22. #include <unistd.h>
  23. #include <string.h>

  25. pthread_cond_t qready;
  26. pthread_mutex_t qlock = PTHREAD_MUTEX_INITIALIZER;

  28. struct foo {
  29.     int cnt;
  30.     pthread_mutex_t f_lock;
  31. };

  33. void cleanup(void *arg)
  34. {
  35.     printf("clean up: %s\n", (char *)arg);
  36. }

  38. void printids(char *str)
  39. {
  40.     printf("%s pid = %u tid = %u / 0x%x\n", 
  41.             str, (unsigned int)getpid(), (unsigned int)pthread_self(), (unsigned int)pthread_self());
  42. }

  44. void *thread1(void *arg)
  45. {
  46.     pthread_mutex_lock(&qlock);
  47.     pthread_cond_wait(&qready, &qlock);
  48.     pthread_mutex_unlock(&qlock);

  50.     printids("thread1:");
  51.     
  52.     pthread_cleanup_push(cleanup, "thread 1 first cleanup handler");
  53.     pthread_cleanup_push(cleanup, "thread 1 second cleanup handler");
  54.     printf("thread 1 push complete!\n");
  55.     
  56.     pthread_mutex_lock(&((struct foo *)arg)->f_lock);
  57.     ((struct foo *)arg)->cnt ;
  58.     printf("thread1: cnt = %d\n", ((struct foo *)arg)->cnt);
  59.     pthread_mutex_unlock(&((struct foo *)arg)->f_lock);

  61.     if (arg) 
  62.         return ((void *)0);
  63.     
  64.     pthread_cleanup_pop(0);
  65.     pthread_cleanup_pop(0);

  67.     pthread_exit((void *)1);
  68. }

  70. void *thread2(void *arg)
  71. {
  72.     int exit_code = -1;
  73.     printids("thread2:");
  74.     
  75.     printf("Now unlock thread1\n");

  77.     pthread_mutex_lock(&qlock);
  78.     pthread_mutex_unlock(&qlock);
  79.     pthread_cond_signal(&qready);

  81.     printf("Thread1 unlocked\n");

  83.     pthread_cleanup_push(cleanup, "thread 2 first cleanup handler");
  84.     pthread_cleanup_push(cleanup, "thread 2 second cleanup handler");
  85.     printf("thread 2 push complete!\n");
  86.     
  87.     if (arg) 
  88.         pthread_exit((void *)exit_code);

  90.     pthread_cleanup_pop(0);
  91.     pthread_cleanup_pop(0);
  92.     
  93.     pthread_exit((void *)exit_code);
  94. }

  96. int main(int argc, char *argv[])
  97. {
  98.     int ret;
  99.     pthread_t tid1, tid2;
  100.     void *retval;
  101.     struct foo *fp;

  103.     ret = pthread_cond_init(&qready, NULL);
  104.     if (ret != 0) {
  105.         printf("pthread_cond_init error: %s\n", strerror(ret));
  106.         return -1;
  107.     }



  111.     if ((fp = malloc(sizeof(struct foo))) == NULL) {
  112.         printf("malloc failed!\n");
  113.         return -1;
  114.     }

  116.     if (pthread_mutex_init(&fp->f_lock, NULL) != 0) {
  117.         free(fp);
  118.         printf("init mutex failed!\n");
  119.     }

  121.     pthread_mutex_lock(&fp->f_lock);

  123.     ret = pthread_create(&tid1, NULL, thread1, (void *)fp);
  124.     if (ret != 0) {
  125.         printf("main thread error: %s\n", strerror(ret));
  126.         return -1;
  127.     }
  128.     ret = pthread_create(&tid2, NULL, thread2, (void *)1);
  129.     if (ret != 0) {
  130.         printf("main thread error: %s\n", strerror(ret));
  131.         return -1;
  132.     }

  134.     
  135.     ret = pthread_join(tid2, &retval);
  136.     if (ret != 0) {
  137.         printf("pthread join falied!\n");
  138.         return -1;
  139.     }
  140.     else
  141.         printf("thread2 exit code %d\n", (int)retval);

  143.     fp->cnt = 1;
  144.     printf("main thread: cnt = %d\n",fp->cnt);

  146.     pthread_mutex_unlock(&fp->f_lock);

  148.     sleep(1);    //there is no guarantee the main thread will run before the newly created thread, so we wait for a while 
  149.     printids("main thread:");

  151.     printf("Press to exit\n");

  153.     ret = pthread_cond_destroy(&qready);
  154.     if (ret != 0) {
  155.         printf("pthread_cond_destroy error: %s\n", strerror(ret));
  156.         return -1;
  157.     }

  159.     getchar();
  160.     return 0;
  161. }

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/313320.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

移除链表元素

移除链表元素

题目描述 删除链表中等于给定值 val 的所有节点。 示例: 输入: 1->2->6->3->4->5->6, val 6 输出: 1->2->3->4->5解法 使用哑结点&#xff0c;只需要变更next指针即可。 /*** Definition for singly-linked list.* public class ListNode …
阅读更多...
VSCode开发.NETCore项目入门（1）设置中文语言环境

VSCode开发.NETCore项目入门（1）设置中文语言环境

安装VSCode最新地址&#xff1a;https://code.visualstudio.com/&#xff0c;下载后安装即可配置语言环境打开安装好的VSCode软件&#xff0c;可以看到刚刚安装的VSCode软件默认使用的是英文语言环境&#xff0c;如下图&#xff1a;使用快捷键【CtrlShiftP】来配置&#xff0c;…
阅读更多...
char *c = abc和char c[]=abc

char *c = abc和char c[]=abc

转自&#xff1a;http://blog.csdn.net/wallwind/article/details/7210474 char *c "abc"和char c[]"abc",前者改变其内 容程序是会崩溃的&#xff0c;而后者完全正确。 程序演示&#xff1a; 测试环境Devc 代码 运行结果 2293628 4199056 abc 2293624 22…
阅读更多...
同构字符串

同构字符串

题目描述 给定两个字符串 s 和 t&#xff0c;判断它们是否是同构的。 如果 s 中的字符可以被替换得到 t &#xff0c;那么这两个字符串是同构的。 所有出现的字符都必须用另一个字符替换&#xff0c;同时保留字符的顺序。两个字符不能映射到同一个字符上&#xff0c;但字符可…
阅读更多...
微软100题第11题

微软100题第11题

参照&#xff1a;http://blog.csdn.net/caryaliu/article/details/8107089 参照&#xff1a;http://blog.csdn.net/lalor/article/details/7626678 把二叉树看成一个图&#xff0c;父子节点之间的连线看成是双向的&#xff0c;我们姑且定义"距离"为两个节点之间的个…
阅读更多...
.NET Core 3.0】框架之十三 || 部署攻略

.NET Core 3.0】框架之十三 || 部署攻略

本文有配套视频&#xff1a;https://www.bilibili.com/video/av58096866/?p9一、部署1、WIN_独立部署感谢群里&#xff08;白云&#xff09;小伙伴&#xff0c;博主 小淋科技 提出的方案(需要 netcore2.1 )&#xff0c;我竟然忽略了&#xff0c;该打该打&#xff0c;官档都读…
阅读更多...
Python import以及os模块

Python import以及os模块

转自&#xff1a;http://jianpx.iteye.com/blog/486466 http://blog.chinaunix.net/uid-27838438-id-4087978.html Import: 1. import 实际上是python虚拟机把当前的globals()和locals()传进__builtins__.__import__内置函数了&#xff0c;所以实际上干活的是那个__import__函…
阅读更多...
移除元素

移除元素

题目描述 给定一个数组 nums 和一个值 val&#xff0c;你需要原地移除所有数值等于 val 的元素&#xff0c;返回移除后数组的新长度。 不要使用额外的数组空间&#xff0c;你必须在原地修改输入数组并在使用 O(1) 额外空间的条件下完成。 元素的顺序可以改变。你不需要考虑数…
阅读更多...
.Net Core3.0 配置Configuration

.Net Core3.0 配置Configuration

准备.NET core和.NET项目配置上有了很大的改变&#xff0c;支持的也更加丰富了比如命令行&#xff0c;环境变量&#xff0c;内存中.NET对象&#xff0c;设置文件等等。.NET项目我们常常把配置信息放到webConfig 或者appConfig中。配置相关的源码https://github.com/aspnet/Exte…
阅读更多...
Python os.makedirs try 以及 raise

Python os.makedirs try 以及 raise

转自&#xff1a;http://bookshadow.com/weblog/2014/10/02/python-mkdir-p/ http://blog.csdn.net/mr_jj_lian/article/details/6786052 mkdir为Linux操作系统中的创建目录命令&#xff0c;使用mkdir -p指令可以自动创建目标目录路径中尚不存在的上级目录&#xff08;Window…
阅读更多...
asp.net core 3.0 中使用 swagger

asp.net core 3.0 中使用 swagger

asp.net core 3.0 中使用 swaggerIntro上次更新了 asp.net core 3.0 简单的记录了一下 swagger 的使用&#xff0c;那个项目的 api 比较简单&#xff0c;都是匿名接口不涉及到认证以及 api 版本控制&#xff0c;最近把另外一个 api 项目升级到了 3.0&#xff0c;还是遇到了一些…
阅读更多...
由微软100题“求和不用for while”引出的static类成员的知识

由微软100题“求和不用for while”引出的static类成员的知识

转自&#xff1a;http://www.cnblogs.com/gysm/archive/2011/09/16/2179277.html C类中谈到static,我们可以在类中定义static成员&#xff0c;static成员函数&#xff01;Cprimer里面讲过&#xff1a;static成员它不像普通的数据成员&#xff0c;static数据成员独立于该类的任意…
阅读更多...
MCN是啥？了解一下这5个互联网热词

MCN是啥？了解一下这5个互联网热词

骗子刷量&#xff0c;黑吃黑半斤八两前几天一件事火爆了互联网圈&#xff0c;一场搞笑的骗局&#xff0c;一场蜂群传媒导演的“僵尸舞台剧”&#xff1a;一条一夜爆红的视频 流量却为0&#xff01;。一个电商商家卖产品有投放需求&#xff0c;找到了微博上一家 MCN 机构的一个女…
阅读更多...
Matlab出现On Startup: Error using eval undefined function 'workspacefunc' for input arguments of type

Matlab出现On Startup: Error using eval undefined function 'workspacefunc' for input arguments of type

按照提示 Warning: MATLAB did not appear to successfully set the search path. To recover for this session of MATLAB, type "restoredefaultpath;matlabrc". To find out how to avoid this warning the next time you start MATLAB, type "docsearch pr…
阅读更多...
为什么我不建议你去外包公司？

为什么我不建议你去外包公司？

前言在我离开上家公司之前&#xff0c;我的直属领导找我聊了一番。除了问候我有没有找好下家之外&#xff0c;还千叮咛万嘱咐我千万不要去外包公司&#xff0c;否则会在简历上留下无法磨灭的污点。当时的我对于外包公司的了解并不深&#xff0c;只是道听途说外包公司很坑&#…
阅读更多...
x 的平方根

x 的平方根

题目描述 实现 int sqrt(int x) 函数。 计算并返回 x 的平方根&#xff0c;其中 x 是非负整数。 由于返回类型是整数&#xff0c;结果只保留整数的部分&#xff0c;小数部分将被舍去。 示例 1: 输入: 4 输出: 2示例 2: 输入: 8 输出: 2 说明: 8 的平方根是 2.82842..., 由…
阅读更多...
Caffe编译代码的时候报各种未定义未声明

Caffe编译代码的时候报各种未定义未声明

自己装的CUDNN是一个版本&#xff0c;而运行别人的code时可能人家对应CUDNN的另一个版本&#xff0c;此时需要修改关键字来兼容版本&#xff0c;参考 1. https://github.com/BVLC/caffe/issues/1792 https://github.com/BVLC/caffe/pull/1739 https://github.com/BVLC/ca…
阅读更多...
友浩达优选上新，原生态农产品，买得安心，吃得放心

友浩达优选上新，原生态农产品，买得安心，吃得放心

大闸蟹还在热卖&#xff0c;需要的同学可以访问 各位一直支持队长的朋友们友浩达优选上新了本着为大家推荐好东西的想法商城里上架的商品都是队长亲自挑选有质量保证的口碑好商品这次&#xff0c;来看看队长又给大家带了哪些好东西本次上新全是各地优选原生态农产品食品优质、安…
阅读更多...
判别学习与生成学习的区别

判别学习与生成学习的区别

参照http://blog.csdn.net/daijiguo/article/details/52218207 比如二类分类问题&#xff0c;不管是感知器算法还是逻辑斯蒂回归算法&#xff0c;都是在解空间中寻找一条直线从而把两种类别的样例分开&#xff0c;对于新的样例只要判断在直线的哪一侧即可&#xff1b;这种直接对…
阅读更多...
树莓派4上跑 .NET Core 3.0，这次，真·64位！

树莓派4上跑 .NET Core 3.0，这次，真·64位！

导语前不久我写了一篇《Gentoo由于 Windows 10 IoT Core &#xff08;以及上面的UWP们&#xff09;暴尸荒野而苟且偷生使用 Linux 的我&#xff0c;已经彻底开荤了。最近我发现有个叫 Gentoo 的 Linux 系统&#xff0c;支持树莓派4的64位CPU。项目地址&#xff1a;https://gith…
阅读更多...
最新文章

Copyright @ 2022~2023