2. 线程控制

2.1. 创建线程

  1. #include <pthread.h>
  2.  
  3. int pthread_create(pthread_t *restrict thread,
  4. const pthread_attr_t *restrict attr,
  5. void *(*start_routine)(void*), void *restrict arg);

返回值:成功返回0,失败返回错误号。以前学过的系统函数都是成功返回0,失败返回-1,而错误号保存在全局变量errno中,而pthread库的函数都是通过返回值返回错误号,虽然每个线程也都有一个errno,但这是为了兼容其它函数接口而提供的,pthread库本身并不使用它,通过返回值返回错误码更加清晰。

在一个线程中调用pthread_create()创建新的线程后,当前线程从pthread_create()返回继续往下执行,而新的线程所执行的代码由我们传给pthread_create的函数指针start_routine决定。start_routine函数接收一个参数,是通过pthread_createarg参数传递给它的,该参数的类型为void *,这个指针按什么类型解释由调用者自己定义。start_routine的返回值类型也是void *,这个指针的含义同样由调用者自己定义。start_routine返回时,这个线程就退出了,其它线程可以调用pthread_join得到start_routine的返回值,类似于父进程调用wait(2)得到子进程的退出状态,稍后详细介绍pthread_join

pthread_create成功返回后,新创建的线程的id被填写到thread参数所指向的内存单元。我们知道进程id的类型是pid_t,每个进程的id在整个系统中是唯一的,调用getpid(2)可以获得当前进程的id,是一个正整数值。线程id的类型是thread_t,它只在当前进程中保证是唯一的,在不同的系统中thread_t这个类型有不同的实现,它可能是一个整数值,也可能是一个结构体,也可能是一个地址,所以不能简单地当成整数用printf打印,调用pthread_self(3)可以获得当前线程的id。

attr参数表示线程属性,本章不深入讨论线程属性,所有代码例子都传NULLattr参数,表示线程属性取缺省值,感兴趣的读者可以参考[APUE2e]。首先看一个简单的例子:

  1. #include <stdio.h>
  2. #include <string.h>
  3. #include <stdlib.h>
  4. #include <pthread.h>
  5. #include <unistd.h>
  6.  
  7. pthread_t ntid;
  8.  
  9. void printids(const char *s)
  10. {
  11. pid_t pid;
  12. pthread_t tid;
  13.  
  14. pid = getpid();
  15. tid = pthread_self();
  16. printf("%s pid %u tid %u (0x%x)\n", s, (unsigned int)pid,
  17. (unsigned int)tid, (unsigned int)tid);
  18. }
  19.  
  20. void *thr_fn(void *arg)
  21. {
  22. printids(arg);
  23. return NULL;
  24. }
  25.  
  26. int main(void)
  27. {
  28. int err;
  29.  
  30. err = pthread_create(&ntid, NULL, thr_fn, "new thread: ");
  31. if (err != 0) {
  32. fprintf(stderr, "can't create thread: %s\n", strerror(err));
  33. exit(1);
  34. }
  35. printids("main thread:");
  36. sleep(1);
  37.  
  38. return 0;
  39. }

编译运行结果如下:

  1. $ gcc main.c -lpthread
  2. $ ./a.out
  3. main thread: pid 7398 tid 3084450496 (0xb7d8fac0)
  4. new thread: pid 7398 tid 3084446608 (0xb7d8eb90)

可知在Linux上,thread_t类型是一个地址值,属于同一进程的多个线程调用getpid(2)可以得到相同的进程号,而调用pthread_self(3)得到的线程号各不相同。

由于pthread_create的错误码不保存在errno中,因此不能直接用perror(3)打印错误信息,可以先用strerror(3)把错误码转换成错误信息再打印。

如果任意一个线程调用了exit_exit,则整个进程的所有线程都终止,由于从main函数return也相当于调用exit,为了防止新创建的线程还没有得到执行就终止,我们在main函数return之前延时1秒,这只是一种权宜之计,即使主线程等待1秒,内核也不一定会调度新创建的线程执行,下一节我们会看到更好的办法。

思考题:主线程在一个全局变量ntid中保存了新创建的线程的id,如果新创建的线程不调用pthread_self而是直接打印这个ntid,能不能达到同样的效果?

2.2. 终止线程

如果需要只终止某个线程而不终止整个进程,可以有三种方法:

  • 从线程函数return。这种方法对主线程不适用,从main函数return相当于调用exit

  • 一个线程可以调用pthread_cancel终止同一进程中的另一个线程。

  • 线程可以调用pthread_exit终止自己。

pthread_cancel终止一个线程分同步和异步两种情况,比较复杂,本章不打算详细介绍,读者可以参考[APUE2e]。下面介绍pthread_exit的和pthread_join的用法。

  1. #include <pthread.h>
  2.  
  3. void pthread_exit(void *value_ptr);

value_ptrvoid *类型,和线程函数返回值的用法一样,其它线程可以调用pthread_join获得这个指针。

需要注意,pthread_exit或者return返回的指针所指向的内存单元必须是全局的或者是用malloc分配的,不能在线程函数的栈上分配,因为当其它线程得到这个返回指针时线程函数已经退出了。

  1. #include <pthread.h>
  2.  
  3. int pthread_join(pthread_t thread, void **value_ptr);

返回值:成功返回0,失败返回错误号

调用该函数的线程将挂起等待,直到id为thread的线程终止。thread线程以不同的方法终止,通过pthread_join得到的终止状态是不同的,总结如下:

  • 如果thread线程通过return返回,value_ptr所指向的单元里存放的是thread线程函数的返回值。

  • 如果thread线程被别的线程调用pthread_cancel异常终止掉,value_ptr所指向的单元里存放的是常数PTHREAD_CANCELED

  • 如果thread线程是自己调用pthread_exit终止的,value_ptr所指向的单元存放的是传给pthread_exit的参数。

如果对thread线程的终止状态不感兴趣,可以传NULLvalue_ptr参数。

看下面的例子(省略了出错处理):

  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <pthread.h>
  4. #include <unistd.h>
  5.  
  6. void *thr_fn1(void *arg)
  7. {
  8. printf("thread 1 returning\n");
  9. return (void *)1;
  10. }
  11.  
  12. void *thr_fn2(void *arg)
  13. {
  14. printf("thread 2 exiting\n");
  15. pthread_exit((void *)2);
  16. }
  17.  
  18. void *thr_fn3(void *arg)
  19. {
  20. while(1) {
  21. printf("thread 3 writing\n");
  22. sleep(1);
  23. }
  24. }
  25.  
  26. int main(void)
  27. {
  28. pthread_t tid;
  29. void *tret;
  30.  
  31. pthread_create(&tid, NULL, thr_fn1, NULL);
  32. pthread_join(tid, &tret);
  33. printf("thread 1 exit code %d\n", (int)tret);
  34.  
  35. pthread_create(&tid, NULL, thr_fn2, NULL);
  36. pthread_join(tid, &tret);
  37. printf("thread 2 exit code %d\n", (int)tret);
  38.  
  39. pthread_create(&tid, NULL, thr_fn3, NULL);
  40. sleep(3);
  41. pthread_cancel(tid);
  42. pthread_join(tid, &tret);
  43. printf("thread 3 exit code %d\n", (int)tret);
  44.  
  45. return 0;
  46. }

运行结果是:

  1. $ ./a.out
  2. thread 1 returning
  3. thread 1 exit code 1
  4. thread 2 exiting
  5. thread 2 exit code 2
  6. thread 3 writing
  7. thread 3 writing
  8. thread 3 writing
  9. thread 3 exit code -1

可见在Linux的pthread库中常数PTHREAD_CANCELED的值是-1。可以在头文件pthread.h中找到它的定义:

  1. #define PTHREAD_CANCELED ((void *) -1)

一般情况下,线程终止后,其终止状态一直保留到其它线程调用pthread_join获取它的状态为止。但是线程也可以被置为detach状态,这样的线程一旦终止就立刻回收它占用的所有资源,而不保留终止状态。不能对一个已经处于detach状态的线程调用pthread_join,这样的调用将返回EINVAL。对一个尚未detach的线程调用pthread_joinpthread_detach都可以把该线程置为detach状态,也就是说,不能对同一线程调用两次pthread_join,或者如果已经对一个线程调用了pthread_detach就不能再调用pthread_join了。

  1. #include <pthread.h>
  2.  
  3. int pthread_detach(pthread_t tid);

返回值:成功返回0,失败返回错误号。