有两个线程T1,T2,都要调用fun()函数,函数内容为:
fun()
{
int len;
...
pthread_setcancelstate(PTHREAD_CANCEL_ENABLE,&iOldState);
pthread_testcancel();
len=read(...);
pthread_setcancelstate(PTHREAD_CANCEL_DISABLE,&iOldState);
...
}
那么read()函数前后的那三句语句是否可以理解为一个锁呢?
比如T1进来调用pthread_setcancelstate(PTHREAD_CANCEL_ENABLE,&iOldState)将T2设置为允许T2在执行到pthread_testcancel()时线程取消,然后T1执行read(),再执行pthread_setcancelstate(PTHREAD_CANCEL_DISABLE,&iOldState)将T2设置为禁止线程取消,然后T2才可以调用read()。这样理解不知对否?
那如果T1设置为线程取消的话T2执行到pthread_testcancel();应该是取消或退出状态,也就是没有T2这个线程了,那么此多线程程序设计不是就没有意义了吗?
还请各位大侠帮忙分析一下吧!谢谢了!
你的理解不对。
首先,pthread_setcancelstate()函数只是改变本线程(注意是本线程)的cancel state。所以T1进入fun()函数,执行到pthread_setcancelstate()函数时,只是改变了T1本身的cancel state,并不能改变T2的cancel state。
第二,线程执行到pthread_testcancel()函数时,并不一定会马上取消(退出)。
先描述一下取消一个线程的过程:
1) 其他线程通过调用pthread_cancel()函数,向目标线程发送取消请求(cancellation request)。
2) 取消请求发出后,根据目标线程的cancel state来决定取消请求是否会到达目标线程:
a. 如果目标线程的cancel state是PTHREAD_CANCEL_ENABLE(默认),取消请求会到达目标线程。
b. 如果目标线程的cancel state是PTHREAD_CANCEL_DISABLE,取消请求会被放入队列。直到目标线程的cancel state变为PTHREAD_CANCEL_ENABLE,取消请求才会从队列里取出,发到目标线程。
3) 取消请求到达目标线程后,根据目标线程的cancel type来决定线程何时取消:
a. 如果目标线程的cancel type是PTHREAD_CANCEL_DEFERRED(默认),目标线程并不会马上取消,而是在执行下一条cancellation point的时候才会取消。有很多系统函数都是cancellation point,详细的列表可以在Linux上用man 7 pthreads查看。除了列出来的cancellation point,pthread_testcancel()也是一个cancellation point。就是说目标线程执行到pthread_testcancel()函数的时候,如果该线程收到过取消请求,而且它的cancel type是PTHREAD_CANCEL_DEFERRED,那么这个线程就会在这个函数里取消(退出),这个函数就不再返回了,目标线程也没有了。
b. 如果目标线程的cancel type是PTHREAD_CANCEL_ASYNCHRONOUS,目标线程会立即取消(这里的“立即”只是说目标线程不用等执行到属于cancellation point的函数的时候才会取消,它会在获得调度之后立即取消,因为内核调度会有延时,所以并不能保证时间上的“立即”)。
举个例子,说明一下这些与线程取消相关的函数的用法:
void thread_function(void *arg)那是不是说没有pthread_setcanceltype()这个函数的话以上的取消动作都是没效的(也就是说虽然到了取消点但是不会取消的)?那么可不可以不加这些线程取消函数?
网上查到又说 “由于LinuxThread库与C库结合得不好,因此可以在需要作为Cancelation-point的系统调用(比如read())前后调用 pthread_testcancel(),从而达到POSIX标准所要求的目标。“ 难道仅仅是为了兼容性?
如果cancel type是disabled,那么到了取消点也不会被取消的。你说“可不可以不加这些线程取消函数”指的是哪段代码里的函数?
pthread_testcancel()函数一方面可以用来使LinuxThread与POSIX一致;另一方面就是如果线程函数里没有作为取消点的函数,就可以用pthread_testcancel()人为地创建取消点,使得该线程一旦收到取消请求就可以被取消。