POSIX的pthread_join

POSIX的pthread_join

http://blog.csdn.net/ba_jie/article/details/6783205

函数pthread_join用来等待一个线程的结束。函数原型为:
  extern int pthread_join __P ((pthread_t __th, void **__thread_return));
  第一个参数为被等待的线程标识符,第二个参数为一个用户定义的指针,它可以用来存储被等待线程的返回值。这个函数是一个线程阻塞的函数,调用它的线程将一直等待到被等待的线程结束为止,当函数返回时,被等待线程的资源被收回。一个线程的结束有两种途径,一种是象我们上面的例子一样,函数结束了,调用它的线程也就结束了;另一种方式是通过函数pthread_exit来实现。它的函数原型为:
  extern void pthread_exit __P ((void *__retval)) __attribute__ ((__noreturn__));
  唯一的参数是函数的返回代码,只要pthread_exit中的参数retval不是NULL,这个值将被传递给 thread_return。最后要说明的是,一个线程不能被多个线程等待,否则第一个接收到信号的线程成功返回,其余调用pthread_join的线程则返回错误代码ESRCH。

join

  • join是三种同步线程的方式之一。另外两种分别是互斥锁(mutex)和条件变量(condition variable)。
  • 调用pthread_join()将阻塞自己,一直到要等待加入的线程运行结束。
  • 可以用pthread_join()获取线程的返回值。
  • 一个线程对应一个pthread_join()调用,对同一个线程进行多次pthread_join()调用是逻辑错误。

join or detach

  • 线程分两种:一种可以join,另一种不可以。该属性在创建线程的时候指定。
  • joinable线程可在创建后,用pthread_detach()显式地分离。但分离后不可以再合并。该操作不可逆。
  • 为了确保移植性,在创建线程时,最好显式指定其join或detach属性。似乎不是所有POSIX实现都是用joinable作默认。
        [cpp]
  1. #include <pthread.h>
  2. #include <stdio.h>
  3. #include <stdlib.h>
  4. #define NUM_THREADS 4
  5. void *BusyWork(void *t)
  6. {
  7. double result=0.0;
  8. long tid = (long)t;
  9. printf("Thread %ld starting...\n",tid);
  10. for (int i=0; i<1000000; i++)
  11. {
  12. result = result + sin(i) * tan(i);
  13. }
  14. printf("Thread %ld done. Result = %e\n",tid, result);
  15. pthread_exit((void*) t);
  16. }
  17. int main (int argc, char *argv[])
  18. {
  19. pthread_t thread[NUM_THREADS];
  20. pthread_attr_t attr;
  21. // 1/4: init
  22. pthread_attr_init(&attr);
  23. // 2/4: explicitly specify as joinable or detached
  24. pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);
  25. int rc;
  26. long t;
  27. for(t=0; t<NUM_THREADS; t++)
  28. {
  29. printf("Main: creating thread %ld\n", t);
  30. // 3/4: use thread attribute
  31. rc = pthread_create(&thread[t], &attr, BusyWork, (void *)t);
  32. if (rc) {
  33. printf("ERROR; return code from pthread_create() is %d\n", rc);
  34. exit(-1);
  35. }
  36. }
  37. // 4/4: release thread attribute
  38. pthread_attr_destroy(&attr);
  39. void *status;
  40. for(t=0; t<NUM_THREADS; t++)
  41. {
  42. rc = pthread_join(thread[t], &status);
  43. if (rc) {
  44. printf("ERROR; return code from pthread_join() is %d\n", rc);
  45. exit(-1);
  46. }
  47. printf("Main: completed join with thread %ld having a status of %ld\n",t,(long)status);
  48. }
  49. printf("Main: program completed. Exiting.\n");
  50. return 0;
  51. }