lienhua34
2014-11-241 取消线程
pthread 提供了pthread_cancel 函数用于请求取消同一进程中的其他线程。
#include <pthread.h>
int pthread_cancel(pthread_t tid);
返回值:若成功则返回0,否则返回错误编码
pthread_cancel 调用并不会立即终止目标线程,而只是向目标线程发出取消请求。调用线程不等待目标线程终止,在默认情况下,目标线程在取消请求发出以后还是继续运行的,直到目标线程到达某个取消点。取消点是线程检查是否被取消并按照请求进行动作的一个位置。
下面我们来看个线程取消的例子。主线程创建一个新线程,新线程循环睡眠 5 秒钟然后返回 2. 而主线程在创建新线程之后睡眠 2 秒钟便调用pthread_cancel 来请求取消新线程。最后获取新线程的退出状态。
#include#include #include #include void *my_thread(void *arg){ int i=0; printf("[new thread]: I will sleep 5 seconds.\n"); while (i < 5) { sleep(1); i = i + 1; printf("[new thread]: %d\n", i); } printf("[new thread]: exit now.\n"); return ((void *)0);}intmain(void){ int err; pthread_t tid; void *tret; err = pthread_create(&tid, NULL, my_thread, NULL); if ( err != 0) { printf("can't create thread: %s\n", strerror(err)); exit(-1); } sleep(2); printf("[main thread]: cancel new thread.\n"); err = pthread_cancel(tid); if (err != 0) { printf("can't cancel thread: %s\n", strerror(err)); exit(-1); } err = pthread_join(tid, &tret); if (err != 0) { printf("can't join with new thread: %s\n", strerror(err)); exit(-1); } else { if (PTHREAD_CANCELED == tret) { printf("new thread has been canceled.\n"); } else { printf("new thread exit code: %d\n", (int)tret); } } exit(0);}
编译该程序,生成并执行文件pthread_cancel_demo,
lienhua34:demo$ gcc -o pthread_cancel_demo -pthread pthread_cancel_demo.clienhua34:demo$ ./pthread_cancel_demo[new thread]: I will sleep 5 seconds.[new thread]: 1[main thread]: cancel new thread.new thread has been canceled.
如果某个线程响应了取消请求相当于调用了参数为PTHREAD_CANCELED的pthread_exit 函数。
2 线程取消属性
前面学习了可以通过pthread_attr_t 结构来控制线程的属性。但是有两个与线程取消的属性没有包含在pthread_attr_t 结构中,它们是可取消状态和可取消类型。
2.1 可取消状态
可取消状态属性是个使能属性,控制了线程是否要响应其他线程的取消请求。该属性可以是PTHREAD_CANCEL_ENABLE,或者是PTHREAD_CANCEL_DISABLE。线程的可取消属性默认为前者。如果设置为后者,则线程将不会响应取消请求,不过取消请求对于该线程来说处于未决状态,当可取消状态再次变为PTHREAD_CANCEL_ENABLE 时,线程将在下个取消点上对所有未决的取消请求进行处理。
线程可以通过调用pthread_setcancelstate 函数来修改其可取消状态。
#include <pthread.h>
int pthread_setcancelstate(int state, int *oldstate);
返回值:若成功则返回0,否则返回错误编号
该函数将线程的当前可取消状态设置为 state,并通过 oldstate 返回原来的可取消状态。
下面我们来看那个例子,我们在上面的pthread_cancel_demo.c 程序的新线程入口函数my_thread 的开始调用pthread_setcancelstate 函数将新线程的可取消状态设置为PTHREAD_CANCEL_DISABLE。
#include#include #include #include void *my_thread(void *arg){ int i=0; int err; err = pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL); if (err != 0) { printf("[new thread]: can't set cancel state: %s\n", strerror(err)); } printf("[new thread: disable cancel state.\n"); printf("[new thread]: I will sleep 5 seconds.\n"); while (i < 5) { sleep(1); i = i + 1; printf("[new thread]: %d\n", i); } printf("[new thread]: exit now.\n"); return ((void *)0);}intmain(void){ int err; pthread_t tid; void *tret; err = pthread_create(&tid, NULL, my_thread, NULL); if ( err != 0) { printf("can't create thread: %s\n", strerror(err)); exit(-1); } sleep(2); printf("[main thread]: cancel new thread.\n"); err = pthread_cancel(tid); if (err != 0) { printf("can't cancel thread: %s\n", strerror(err)); exit(-1); } err = pthread_join(tid, &tret); if (err != 0) { printf("can't join with new thread: %s\n", strerror(err)); exit(-1); } else { if (PTHREAD_CANCELED == tret) { printf("new thread has been canceled.\n"); } else { printf("new thread exit code: %d\n", (int)tret); } } exit(0);}
编译该程序,生成并执行pthread_cancel_demo 文件,
lienhua34:demo$ gcc -o pthread_cancel_demo -pthread pthread_cancel_demo.clienhua34:demo$ ./pthread_cancel_demo[new thread: disable cancel state.[new thread]: I will sleep 5 seconds.[new thread]: 1[main thread]: cancel new thread.[new thread]: 2[new thread]: 3[new thread]: 4[new thread]: 5[new thread]: exit now.new thread exit code: 0
从上面的运行结果与前一节的运行结果对比,我们可以看出将新线程的可取消状态设置为PTHREAD_CANCEL_DISABLE 后,新线程没有响应主线程的取消请求。
2.2 可取消类型
上面所说的线程在到达某个取消点的时候会去检查一下是否被取消。这种取消类型也称为延迟取消。另外,还有一种取消类型是异步取消。当线程的取消类型为异步取消时,线程可以在任意时间被取消。
线程可以通过调用pthread_setcanceltype 来修改线程的取消类型。
#include <pthread.h>
int pthread_setcanceltype(int type, int *oldtype);
返回值:若成功则返回0,否则返回错误编号
其中type参数可以是PTHREAD_CANCEL_DEFERRED(延迟取消), 或者PTHREAD_CANCEL_ASYNCHRONOUS(异步取消)。该函数将线程的当前可取消类型设置为 type,然后将原来的可取消类型通过 oldtype 参数返回。
(done)