Posix线程编程指南.docx

《Posix线程编程指南.docx》由会员分享，可在线阅读，更多相关《Posix线程编程指南.docx（28页珍藏版）》请在taowenge.com淘文阁网|工程机械CAD图纸|机械工程制图|CAD装配图下载|SolidWorks_CaTia_CAD_UG_PROE_设计图分享下载上搜索。

1、1. Posix线程编程指南(1) 2. 3.4. 内容： 5.6. 一、 线程创建 7. 二、线程取消 8. 关于作者 9.10.11.12.13. 线程创建与取消 14. 杨沙洲(pubb)15. 2001 年 10 月16.17. 这是一个关于Posix线程编程的专栏。作者在阐明概念的基础上，将向您详细讲述Posix线程库API。本文是第一篇将向您讲述线程的创建与取消。18. 一、线程创建19.20. 11 线程与进程21. 相对进程而言，线程是一个更加接近于执行体的概念，它可以与同进程中的其他线程共享数据，但拥有自己的栈空间，拥有独立的执行序列。在串行程序基础上引入线程和进程是为了提高

2、程序的并发度，从而提高程序运行效率和响应时间。22.23. 线程和进程在使用上各有优缺点：线程执行开销小，但不利于资源的管理和保护；而进程正相反。同时，线程适合于在SMP机器上运行，而进程则可以跨机器迁移。24.25. 12 创建线程26. POSIX通过pthread_create()函数创建线程，API定义如下：27.28. intpthread_create(pthread_t*thread, pthread_attr_t * attr, 29. void * (*start_routine)(void *), void * arg)30.31.32.33. 与fork()调用创建一个进

3、程的方法不同，pthread_create()创建的线程并不具备与主线程（即调用pthread_create()的线程）同样的执行序列，而是使其运行start_routine(arg)函数。thread返回创建的线程ID，而attr是创建线程时设置的线程属性（见下）。pthread_create()的返回值表示线程创建是否成功。尽管arg是void *类型的变量，但它同样可以作为任意类型的参数传给start_routine()函数；同时，start_routine()可以返回一个void *类型的返回值，而这个返回值也可以是其他类型，并由pthread_join()获取。34.35.36. 1

4、3 线程创建属性37. pthread_create()中的attr参数是一个结构指针，结构中的元素分别对应着新线程的运行属性，主要包括以下几项：38.39. _detachstate，表示新线程是否与进程中其他线程脱离同步，如果置位则新线程不能用pthread_join()来同步，且在退出时自行释放所占用的资源。缺省为PTHREAD_CREATE_JOINABLE状态。这个属性也可以在线程创建并运行以后用pthread_detach()来设置，而一旦设置为PTHREAD_CREATE_DETACH状态（不论是创建时设置还是运行时设置）则不能再恢复到PTHREAD_CREATE_JOINABL

5、E状态。40.41. _schedpolicy，表示新线程的调度策略，主要包括SCHED_OTHER（正常、非实时）、SCHED_RR（实时、轮转法）和SCHED_FIFO（实时、先入先出）三种，缺省为SCHED_OTHER，后两种调度策略仅对超级用户有效。运行时可以用过pthread_setschedparam()来改变。42.43. _schedparam，一个struct sched_param结构，目前仅有一个sched_priority整型变量表示线程的运行优先级。这个参数仅当调度策略为实时（即SCHED_RR或SCHED_FIFO）时才有效，并可以在运行时通过pthread_set

6、schedparam()函数来改变，缺省为0。44.45. _inheritsched，有两种值可供选择：PTHREAD_EXPLICIT_SCHED和PTHREAD_INHERIT_SCHED，前者表示新线程使用显式指定调度策略和调度参数（即attr中的值），而后者表示继承调用者线程的值。缺省为PTHREAD_EXPLICIT_SCHED。46.47. _scope，表示线程间竞争CPU的范围，也就是说线程优先级的有效范围。POSIX的标准中定义了两个值：PTHREAD_SCOPE_SYSTEM和PTHREAD_SCOPE_PROCESS，前者表示与系统中所有线程一起竞争CPU时间，后者表示

7、仅与同进程中的线程竞争CPU。目前LinuxThreads仅实现了PTHREAD_SCOPE_SYSTEM一值。48.49. pthread_attr_t结构中还有一些值，但不使用pthread_create()来设置。50.51. 为了设置这些属性，POSIX定义了一系列属性设置函数，包括pthread_attr_init()、pthread_attr_destroy()和与各个属性相关的pthread_attr_get-/pthread_attr_set-函数。52.53. 14 线程创建的Linux实现54. 我们知道，Linux的线程实现是在核外进行的，核内提供的是创建进程的接口do_

8、fork()。内核提供了两个系统调用_clone()和fork()，最终都用不同的参数调用do_fork()核内API。当然，要想实现线程，没有核心对多进程（其实是轻量级进程）共享数据段的支持是不行的，因此，do_fork()提供了很多参数，包括CLONE_VM（共享内存空间）、CLONE_FS（共享文件系统信息）、CLONE_FILES（共享文件描述符表）、CLONE_SIGHAND（共享信号句柄表）和CLONE_PID（共享进程ID，仅对核内进程，即0号进程有效）。当使用fork系统调用时，内核调用do_fork()不使用任何共享属性，进程拥有独立的运行环境，而使用pthread_crea

9、te()来创建线程时,则最终设置了所有这些属性来调用_clone()，而这些参数又全部传给核内的do_fork()，从而创建的进程拥有共享的运行环境，只有栈是独立的，由_clone()传入。55.56. Linux线程在核内是以轻量级进程的形式存在的，拥有独立的进程表项，而所有的创建、同步、删除等操作都在核外pthread库中进行。pthread库使用一个管理线程（_pthread_manager()，每个进程独立且唯一）来管理线程的创建和终止，为线程分配线程ID，发送线程相关的信号（比如Cancel），而主线程（pthread_create()）的调用者则通过管道将请求信息传给管理线程。57

10、.58. 二、线程取消59.60. 21 线程取消的定义61. 一般情况下，线程在其主体函数退出的时候会自动终止，但同时也可以因为接收到另一个线程发来的终止（取消）请求而强制终止。62.63. 22 线程取消的语义64. 线程取消的方法是向目标线程发Cancel信号，但如何处理Cancel信号则由目标线程自己决定，或者忽略、或者立即终止、或者继续运行至Cancelation-point（取消点），由不同的Cancelation状态决定。65.66. 线程接收到CANCEL信号的缺省处理（即pthread_create()创建线程的缺省状态）是继续运行至取消点，也就是说设置一个CANCELED状

11、态，线程继续运行，只有运行至Cancelation-point的时候才会退出。67.68. 23 取消点69. 根据POSIX标准，pthread_join()、pthread_testcancel()、pthread_cond_wait()、pthread_cond_timedwait()、sem_wait()、sigwait()等函数以及read()、write()等会引起阻塞的系统调用都是Cancelation-point，而其他pthread函数都不会引起Cancelation动作。但是pthread_cancel的手册页声称，由于LinuxThread库与C库结合得不好，因而目前C库

12、函数都不是Cancelation-point；但CANCEL信号会使线程从阻塞的系统调用中退出，并置EINTR错误码，因此可以在需要作为Cancelation-point的系统调用前后调用pthread_testcancel()，从而达到POSIX标准所要求的目标，即如下代码段：70.71. pthread_testcancel();72. retcode = read(fd, buffer, length);73. pthread_testcancel();74.75.76.77.78.79. 24 程序设计方面的考虑80. 如果线程处于无限循环中，且循环体内没有执行至取消点的必然路径，则线

13、程无法由外部其他线程的取消请求而终止。因此在这样的循环体的必经路径上应该加入pthread_testcancel()调用。81.82. 25 与线程取消相关的pthread函数83. int pthread_cancel(pthread_t thread)84. 发送终止信号给thread线程，如果成功则返回0，否则为非0值。发送成功并不意味着thread会终止。85.86. int pthread_setcancelstate(int state, int *oldstate)87. 设置本线程对Cancel信号的反应，state有两种值：PTHREAD_CANCEL_ENABLE（缺省）和

14、PTHREAD_CANCEL_DISABLE，分别表示收到信号后设为CANCLED状态和忽略CANCEL信号继续运行；old_state如果不为NULL则存入原来的Cancel状态以便恢复。88.89. int pthread_setcanceltype(int type, int *oldtype)90. 设置本线程取消动作的执行时机，type由两种取值：PTHREAD_CANCEL_DEFFERED和PTHREAD_CANCEL_ASYCHRONOUS，仅当Cancel状态为Enable时有效，分别表示收到信号后继续运行至下一个取消点再退出和立即执行取消动作（退出）；oldtype如果不为

15、NULL则存入运来的取消动作类型值。91.92. void pthread_testcancel(void)93. 检查本线程是否处于Canceld状态，如果是，则进行取消动作，否则直接返回。94.95. 关于作者 96. 杨沙洲，男，现攻读国防科大计算机学院计算机软件方向博士学位。您可以通过电子邮件pubb 跟他联系。 97. (c) Copyright IBM Corp. 2001, (c) Copyright IBM China 2001, All Right Reserved 98. 关于 IBM|隐私条约|使用条款|联系 IBM 99.100. -101. Posix线程编程指南(2

16、) 102. 103. 内容： 104.105. 一 概念及作用 106. 二 创建和注销 107. 三 访问 108. 四 使用范例 109. 关于作者 110.111.112. 相关内容： 113.114. (1) 线程创建与取消115.116.117.118.119. 线程私有数据 120. 杨沙洲(pubb)121. 2001 年 10 月122.123. 这是一个关于Posix线程编程的专栏。作者在阐明概念的基础上，将向您详细讲述Posix线程库API。本文是第二篇将向您讲述线程的私有数据。124. 一概念及作用125. 在单线程程序中，我们经常要用到全局变量以实现多个函数间共享数据

17、。在多线程环境下，由于数据空间是共享的，因此全局变量也为所有线程所共有。但有时应用程序设计中有必要提供线程私有的全局变量，仅在某个线程中有效，但却可以跨多个函数访问，比如程序可能需要每个线程维护一个链表，而使用相同的函数操作，最简单的办法就是使用同名而不同变量地址的线程相关数据结构。这样的数据结构可以由Posix线程库维护，称为线程私有数据（Thread-specific Data，或TSD）。126.127. 二创建和注销128. Posix定义了两个API分别用来创建和注销TSD：129.130. int pthread_key_create(pthread_key_t *key, voi

18、d (*destr_function) (void *)131.132. 该函数从TSD池中分配一项，将其值赋给key供以后访问使用。如果destr_function不为空，在线程退出（pthread_exit()）时将以key所关联的数据为参数调用destr_function()，以释放分配的缓冲区。133.134. 不论哪个线程调用pthread_key_create()，所创建的key都是所有线程可访问的，但各个线程可根据自己的需要往key中填入不同的值，这就相当于提供了一个同名而不同值的全局变量。在LinuxThreads的实现中，TSD池用一个结构数组表示：135.136. stat

19、ic struct pthread_key_struct pthread_keysPTHREAD_KEYS_MAX = 0, NULL ;137.138. 创建一个TSD就相当于将结构数组中的某一项设置为in_use，并将其索引返回给*key，然后设置destructor函数为destr_function。139.140. 注销一个TSD采用如下API：141.142. int pthread_key_delete(pthread_key_t key)143.144. 这个函数并不检查当前是否有线程正使用该TSD，也不会调用清理函数（destr_function），而只是将TSD释放以供下一次

20、调用pthread_key_create()使用。在LinuxThreads中，它还会将与之相关的线程数据项设为NULL（见访问）。145.146. 三访问147. TSD的读写都通过专门的Posix Thread函数进行，其API定义如下：148.149. intpthread_setspecific(pthread_key_tkey,const void*pointer)150. void * pthread_getspecific(pthread_key_t key)151.152.153.154.155.156.157. 写入（pthread_setspecific()）时，将poin

21、ter的值（不是所指的内容）与key相关联，而相应的读出函数则将与key相关联的数据读出来。数据类型都设为void *，因此可以指向任何类型的数据。158.159. 在LinuxThreads中，使用了一个位于线程描述结构（_pthread_descr_struct）中的二维void *指针数组来存放与key关联的数据，数组大小由以下几个宏来说明：160.161. #define PTHREAD_KEY_2NDLEVEL_SIZE 32162. #define PTHREAD_KEY_1STLEVEL_SIZE 163. (PTHREAD_KEYS_MAX + PTHREAD_KEY_2NDL

22、EVEL_SIZE - 1)164. / PTHREAD_KEY_2NDLEVEL_SIZE)165. 其中在/usr/include/bits/local_lim.h中定义了PTHREAD_KEYS_MAX为1024，因此一维数组大小为32。而具体存放的位置由key值经过以下计算得到：166. idx1st = key / PTHREAD_KEY_2NDLEVEL_SIZE167. idx2nd = key % PTHREAD_KEY_2NDLEVEL_SIZE168.169.170.171.172.173. 也就是说，数据存放与一个3232的稀疏矩阵中。同样，访问的时候也由key值经过类似

23、计算得到数据所在位置索引，再取出其中内容返回。174.175. 四使用范例176. 以下这个例子没有什么实际意义，只是说明如何使用，以及能够使用这一机制达到存储线程私有数据的目的。177.178. #include ;179. #include ;180.181. pthread_key_t key;182.183. void echomsg(int t)184. 185. printf(destructor excuted in thread %d,param=%dn,pthread_self(),t);186. 187.188. void * child1(void *arg)189. 1

24、90. int tid=pthread_self();191. printf(thread %d entern,tid);192. pthread_setspecific(key,(void *)tid);193. sleep(2);194. printf(thread %d returns %dn,tid,pthread_getspecific(key);195. sleep(5);196. 197.198. void * child2(void *arg)199. 200. int tid=pthread_self();201. printf(thread %d entern,tid);2

25、02. pthread_setspecific(key,(void *)tid);203. sleep(1);204. printf(thread %d returns %dn,tid,pthread_getspecific(key);205. sleep(5);206. 207.208. int main(void)209. 210. int tid1,tid2;211.212. printf(hellon);213. pthread_key_create(&key,echomsg);214. pthread_create(&tid1,NULL,child1,NULL);215. pthre

26、ad_create(&tid2,NULL,child2,NULL);216. sleep(10);217. pthread_key_delete(key);218. printf(main thread exitn);219. return 0;220. 221.222.223.224.225.226. 给例程创建两个线程分别设置同一个线程私有数据为自己的线程ID，为了检验其私有性，程序错开了两个线程私有数据的写入和读出的时间，从程序运行结果可以看出，两个线程对TSD的修改互不干扰。同时，当线程退出时，清理函数会自动执行，参数为tid。227.228.229.230. Posix线程编程指南(

27、3) 231.232.233. 234. 内容： 235.236. 一 互斥锁 237. 二 条件变量 238. 三 信号灯 239. 四 异步信号 240. 五 其他同步方式 241. 关于作者 242.243.244. 相关内容： 245.246. (1) 线程创建与取消247. (2) 线程私有数据248.249.250.251.252. 线程同步 253. 杨沙洲(pubb)254. 2001 年 10 月255.256. 这是一个关于Posix线程编程的专栏。作者在阐明概念的基础上，将向您详细讲述Posix线程库API。本文是第三篇，将向您讲述线程同步。257. 一互斥锁258. 尽

28、管在Posix Thread中同样可以使用IPC的信号量机制来实现互斥锁mutex功能，但显然semphore的功能过于强大了，在Posix Thread中定义了另外一套专门用于线程同步的mutex函数。259.260. 1 创建和销毁261. 有两种方法创建互斥锁，静态方式和动态方式。POSIX定义了一个宏PTHREAD_MUTEX_INITIALIZER来静态初始化互斥锁，方法如下：262. pthread_mutex_t mutex=PTHREAD_MUTEX_INITIALIZER;263. 在LinuxThreads实现中，pthread_mutex_t是一个结构，而PTHREAD_

29、MUTEX_INITIALIZER则是一个结构常量。264.265. 动态方式是采用pthread_mutex_init()函数来初始化互斥锁，API定义如下：266. int pthread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t *mutexattr)267. 其中mutexattr用于指定互斥锁属性（见下），如果为NULL则使用缺省属性。268.269. pthread_mutex_destroy()用于注销一个互斥锁，API定义如下：270. int pthread_mutex_destroy(pthre

30、ad_mutex_t *mutex)271. 销毁一个互斥锁即意味着释放它所占用的资源，且要求锁当前处于开放状态。由于在Linux中，互斥锁并不占用任何资源，因此LinuxThreads中的pthread_mutex_destroy()除了检查锁状态以外（锁定状态则返回EBUSY）没有其他动作。272.273. 2 互斥锁属性274. 互斥锁的属性在创建锁的时候指定，在LinuxThreads实现中仅有一个锁类型属性，不同的锁类型在试图对一个已经被锁定的互斥锁加锁时表现不同。当前（glibc2.2.3,linuxthreads0.9）有四个值可供选择：275.276. PTHREAD_MUTE

31、X_TIMED_NP，这是缺省值，也就是普通锁。当一个线程加锁以后，其余请求锁的线程将形成一个等待队列，并在解锁后按优先级获得锁。这种锁策略保证了资源分配的公平性。 277. PTHREAD_MUTEX_RECURSIVE_NP，嵌套锁，允许同一个线程对同一个锁成功获得多次，并通过多次unlock解锁。如果是不同线程请求，则在加锁线程解锁时重新竞争。 278. PTHREAD_MUTEX_ERRORCHECK_NP，检错锁，如果同一个线程请求同一个锁，则返回EDEADLK，否则与PTHREAD_MUTEX_TIMED_NP类型动作相同。这样就保证当不允许多次加锁时不会出现最简单情况下的死锁。

32、279. PTHREAD_MUTEX_ADAPTIVE_NP，适应锁，动作最简单的锁类型，仅等待解锁后重新竞争。 280.281.282.283. 3 锁操作284. 锁操作主要包括加锁pthread_mutex_lock()、解锁pthread_mutex_unlock()和测试加锁pthread_mutex_trylock()三个，不论哪种类型的锁，都不可能被两个不同的线程同时得到，而必须等待解锁。对于普通锁和适应锁类型，解锁者可以是同进程内任何线程；而检错锁则必须由加锁者解锁才有效，否则返回EPERM；对于嵌套锁，文档和实现要求必须由加锁者解锁，但实验结果表明并没有这种限制，这个不同目前

33、还没有得到解释。在同一进程中的线程，如果加锁后没有解锁，则任何其他线程都无法再获得锁。285.286. int pthread_mutex_lock(pthread_mutex_t *mutex)287. int pthread_mutex_unlock(pthread_mutex_t *mutex)288. int pthread_mutex_trylock(pthread_mutex_t *mutex)289.290. pthread_mutex_trylock()语义与pthread_mutex_lock()类似，不同的是在锁已经被占据时返回EBUSY而不是挂起等待。291.292. 4

34、 其他293. POSIX线程锁机制的Linux实现都不是取消点，因此，延迟取消类型的线程不会因收到取消信号而离开加锁等待。值得注意的是，如果线程在加锁后解锁前被取消，锁将永远保持锁定状态，因此如果在关键区段内有取消点存在，或者设置了异步取消类型，则必须在退出回调函数中解锁。294.295. 这个锁机制同时也不是异步信号安全的，也就是说，不应该在信号处理过程中使用互斥锁，否则容易造成死锁。296.297. 二条件变量298. 条件变量是利用线程间共享的全局变量进行同步的一种机制，主要包括两个动作：一个线程等待条件变量的条件成立而挂起；另一个线程使条件成立（给出条件成立信号）。为了防止竞争，条件

35、变量的使用总是和一个互斥锁结合在一起。299.300. 1 创建和注销301. 条件变量和互斥锁一样，都有静态动态两种创建方式，静态方式使用PTHREAD_COND_INITIALIZER常量，如下：302. pthread_cond_t cond=PTHREAD_COND_INITIALIZER303.304. 动态方式调用pthread_cond_init()函数，API定义如下：305. int pthread_cond_init(pthread_cond_t *cond, pthread_condattr_t *cond_attr)306.307. 尽管POSIX标准中为条件变量定义了

36、属性，但在LinuxThreads中没有实现，因此cond_attr值通常为NULL，且被忽略。308.309. 注销一个条件变量需要调用pthread_cond_destroy()，只有在没有线程在该条件变量上等待的时候才能注销这个条件变量，否则返回EBUSY。因为Linux实现的条件变量没有分配什么资源，所以注销动作只包括检查是否有等待线程。API定义如下：310. int pthread_cond_destroy(pthread_cond_t *cond)311.312. 2 等待和激发313. int pthread_cond_wait(pthread_cond_t *cond, pt

37、hread_mutex_t *mutex)314. int pthread_cond_timedwait(pthread_cond_t *cond, pthread_mutex_t *mutex, const struct timespec *abstime)315.316. 等待条件有两种方式：无条件等待pthread_cond_wait()和计时等待pthread_cond_timedwait()，其中计时等待方式如果在给定时刻前条件没有满足，则返回ETIMEOUT，结束等待，其中abstime以与time()系统调用相同意义的绝对时间形式出现，0表示格林尼治时间1970年1月1日0时0分

38、0秒。317.318. 无论哪种等待方式，都必须和一个互斥锁配合，以防止多个线程同时请求pthread_cond_wait()（或pthread_cond_timedwait()，下同）的竞争条件（Race Condition）。mutex互斥锁必须是普通锁（PTHREAD_MUTEX_TIMED_NP）或者适应锁（PTHREAD_MUTEX_ADAPTIVE_NP），且在调用pthread_cond_wait()前必须由本线程加锁（pthread_mutex_lock()），而在更新条件等待队列以前，mutex保持锁定状态，并在线程挂起进入等待前解锁。在条件满足从而离开pthread_con

39、d_wait()之前，mutex将被重新加锁，以与进入pthread_cond_wait()前的加锁动作对应。319.320. 激发条件有两种形式，pthread_cond_signal()激活一个等待该条件的线程，存在多个等待线程时按入队顺序激活其中一个；而pthread_cond_broadcast()则激活所有等待线程。321.322. 3 其他323. pthread_cond_wait()和pthread_cond_timedwait()都被实现为取消点，因此，在该处等待的线程将立即重新运行，在重新锁定mutex后离开pthread_cond_wait()，然后执行取消动作。也就是说

40、如果pthread_cond_wait()被取消，mutex是保持锁定状态的，因而需要定义退出回调函数来为其解锁。324.325. 以下示例集中演示了互斥锁和条件变量的结合使用，以及取消对于条件等待动作的影响。在例子中，有两个线程被启动，并等待同一个条件变量，如果不使用退出回调函数（见范例中的注释部分），则tid2将在pthread_mutex_lock()处永久等待。如果使用回调函数，则tid2的条件等待及主线程的条件激发都能正常工作。326.327. #include ;328. #include ;329. #include ;330.331. pthread_mutex_t mutex

41、;332. pthread_cond_tcond;333.334. void * child1(void *arg)335. 336. pthread_cleanup_push(pthread_mutex_unlock,&mutex);/* comment 1 */337. while(1)338. printf(thread 1 get running n);339. printf(thread 1 pthread_mutex_lock returns %dn,340. pthread_mutex_lock(&mutex);341. pthread_cond_wait(&cond,&mute

42、x);342. printf(thread 1 condition appliedn);343. pthread_mutex_unlock(&mutex);344. sleep(5);345. 346. pthread_cleanup_pop(0); /* comment 2 */347. 348.349. void *child2(void *arg)350. 351. while(1)352. sleep(3); /* comment 3 */353. printf(thread 2 get running.n);354. printf(thread 2 pthread_mutex_loc

43、k returns %dn,355. pthread_mutex_lock(&mutex);356. pthread_cond_wait(&cond,&mutex);357. printf(thread 2 condition appliedn);358. pthread_mutex_unlock(&mutex);359. sleep(1);360. 361. 362.363. int main(void)364. 365. int tid1,tid2;366.367. printf(hello, condition variable testn);368. pthread_mutex_ini

44、t(&mutex,NULL);369. pthread_cond_init(&cond,NULL);370. pthread_create(&tid1,NULL,child1,NULL);371. pthread_create(&tid2,NULL,child2,NULL);372. do373. sleep(2); /* comment 4 */374. pthread_cancel(tid1); /* comment 5 */375. sleep(2); /* comment 6 */376. pthread_cond_signal(&cond);377. while(1);378. sleep(100);379. pthread_exit(0);38