线程撤销(pthread_cancel)

矫情吗；* 2022-12-01 05:29 238阅读 0赞

## 简介 ##

`pthread_cancel`调用并不等待线程终止，只提出撤销请求。线程在撤销请求(`pthread_cancel`)发出后*仍会继续运行*，  
直到到达某个**撤销点**(`CancellationPoint`)。撤销点是线程检查是否被撤销并按照请求进行动作的一个位置。

线程撤销和线程取消含义相同，撤销点和取消点都是`CancellationPoint`。

## 线程撤销相关函数 ##

int pthread_cancel(pthread_t thread);

发送终止信号给thread线程，如果成功则返回0，否则为非0值。发送成功并不意味着thread会终止。

int pthread_setcancelstate(int state,   int *oldstate);

设置本线程对Cancel信号的反应，state有两种值：`PTHREAD_CANCEL_ENABLE`（**缺省值**）和`PTHREAD_CANCEL_DISABLE`，  
分别表示收到信号后设为`CANCLED`状态和忽略`CANCEL`信号继续运行；old\_state如果不为`NULL`则存入原来的Cancel状态以便恢复。

int pthread_setcanceltype(int type, int *oldtype);

设置本线程撤销动作的执行时机，type由两种取值：`PTHREAD_CANCEL_DEFFERED`（**缺省值**）和`PTHREAD_CANCEL_ASYCHRONOUS`，仅当Cancel状态为Enable时有效，分别表示收到信号后继续运行至下一个撤销点再退出和立即执行撤销动作（退出）；oldtype如果不为NULL则存入运来的撤销动作类型值。

void pthread_testcancel(void);

`pthread_testcancel`在不包含撤销点，但又需要撤销点的地方创建一个撤销点，以便在一个没有包含撤销点的执行代码线程中响应撤销请求。  
线程撤销功能处于启用状态且撤销状态设置为延迟状态时，`pthread_testcancel()`函数有效。如果在撤销功能处处于禁用状态下调用`pthread_testcancel()`，则该函数不起作用。  
请务必仅在线程撤销线程操作安全的序列中插入`pthread_testcancel()`。除通过`pthread_testcancel()`调用以编程方式建立的撤销点意外，pthread标准还指定了几个撤销点。测试退出点，就是测试cancel信号。

## 撤销点 ##

线程撤销的方法是向目标线程发Cancel信号，但如何处理Cancel信号则由目标线程自己决定，或者忽略、或者立即终止、或者继续运行至`Cancelation-point`（撤销点），由不同的Cancelation状态决定。

线程接收到`CANCE`L信号的缺省处理（即`pthread_create()`创建线程的缺省状态）是**继续运行至撤销点**，也就是说设置一个`CANCELED`状态，线程继续运行，只有运行至`Cancelation-point`的时候才会退出。

`pthreads`标准指定了几个撤销点，其中包括：

1.  通过pthread\_testcancel调用以编程方式建立线程撤销点。
2.  线程等待pthread\_cond\_wait或pthread\_cond\_timewait()中的特定条件。
3.  被sigwait(2)阻塞的函数;
4.  一些标准的库调用。通常，这些调用包括线程可基于阻塞的函数。

缺省情况下，将启用撤销功能。有时，您可能希望应用程序禁用撤销功能。如果禁用撤销功能，则会导致延迟所有的撤销请求，  
直到再次启用撤销请求。

根据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库函数都不是`Cancelation-point`；但`CANCEL`信号会使线程从阻塞的系统调用中退出，并置`EINTR`错误码，因此可以在需要作为`Cancelation-point`的系统调用前后调用`pthread_testcancel()`，从而达到POSIX标准所要求的目标. 即如下代码段：

pthread_testcancel();
    retcode = read(fd, buffer, length);
    pthread_testcancel();

**注意**：  
程序设计方面的考虑,如果线程处于无限循环中，且循环体内没有执行至撤销点的必然路径，则线程无法由外部其他线程的撤销请求而终止。因此在这样的循环体的必经路径上应该加入`pthread_testcancel()`调用.

## 撤销类型(Cancellation Type) ##

我们会发现，通常的说法：某某函数是 `Cancellation Points`，这种方法是容易令人混淆的。  
因为函数的执行是一个时间过程，而不是一个时间点。其实真正的 `Cancellation Points` 只是在这些函数中 `Cancellation Type` 被修改为 `PHREAD_CANCEL_ASYNCHRONOUS` 和修改回 `PTHREAD_CANCEL_DEFERRED` 中间的一段时间。

POSIX的撤销类型有两种，一种是**延迟撤销**(`PTHREAD_CANCEL_DEFERRED`)，这是系统默认的撤销类型，即在线程到达撤销点之前，不会出现真正的撤销；另外一种是**异步撤销**(`PHREAD_CANCEL_ASYNCHRONOUS`)，使用异步撤销时，线程可以在任意时间撤销。

## 线程终止的清理工作 ##

Posix的线程终止有两种情况：**正常终止**和**异常终止**。  
线程主动调用`pthread_exit()`或者从线程函数中return都将使线程正常退出，这是可预见的退出方式；异常终止是线程在其他线程的干预下，或者由于自身运行出错（比如访问非法地址）而退出，这种退出方式是不可预见的。

不论是可预见的线程终止还是异常终止，都会存在资源释放的问题，在不考虑因运行出错而退出的前提下，如何保证线程终止时能顺利的释放掉自己所占用的资源，特别是锁资源，就是一个必须考虑解决的问题。

最经常出现的情形是资源独占锁的使用：线程为了访问临界资源而为其加上锁，但在访问过程中被外界撤销，如果线程处于响应撤销状态，且采用异步方式响应，或者在打开独占锁以前的运行路径上存在撤销点，则该临界资源将永远处于锁定状态得不到释放。外界撤销操作是不可预见的，因此的确需要一个机制来简化用于资源释放的编程。

在POSIX线程API中提供了一个`pthread_cleanup_push()/pthread_cleanup_pop()`函数,  
对用于自动释放资源—从`pthread_cleanup_push()`的调用点到`pthread_cleanup_pop()`之间的程序段中的终止动作（包括调用`pthread_exit()`和撤销点终止）都将执行`pthread_cleanup_push()`所指定的清理函数。

API定义如下：

void pthread_cleanup_push(void (*routine) (void *), void *arg);
    void pthread_cleanup_pop(int execute);

`pthread_cleanup_push()/pthread_cleanup_pop()`采用先入后出的栈结构管理，`void routine(void *arg)`函数  
在调用`pthread_cleanup_push()`时压入清理函数栈，多次对`pthread_cleanup_push()` 的调用将在清理函数栈中形成一个函数链；从`pthread_cleanup_push`的调用点到`pthread_cleanup_pop`之间的程序段中的终止动作（包括调用`pthread_exit()`和异常终止，不包括return）都将执行`pthread_cleanup_push()`所指定的清理函数。

在执行该函数链时按照压栈的相反顺序弹出。execute参数表示执行到 `pthread_cleanup_pop()`时是否在弹出清理函数的同时执行该函数，为0表示不执行，非0为执行；这个参数并不影响异常终止时清理函数的执行。

`pthread_cleanup_push()/pthread_cleanup_pop()`是以宏方式实现的，这是pthread.h中的宏定义：

#define pthread_cleanup_push(routine,arg) \ 
    {  
    struct _pthread_cleanup_buffer _buffer; \ 
    _pthread_cleanup_push (&_buffer, (routine), (arg));
    
    #define pthread_cleanup_pop(execute) \ 
    _pthread_cleanup_pop (&_buffer, (execute)); \
    }

可见，pthread\_cleanup\_push()带有一个"\{"，而pthread\_cleanup\_pop()带有一个"\}"，因此这两个函数必须成对出现，且必须位于程序的同一级别的代码段中才能通过编译。

在下面的例子里，当线程在"do some work"中终止时，将主动调用pthread\_mutex\_unlock(mut)，以完成解锁动作。

pthread_cleanup_push(pthread_mutex_unlock, (void*) &mut);
    pthread_mutex_lock(&mut);
    /* do some work */
    pthread_mutex_unlock(&mut);
    pthread_cleanup_pop(0);
    或者
    void cleanup(void *arg)
    {     
        pthread_mutex_unlock(&mutex);
    }
    
    void* thread0(void* arg)
    {     
        pthread_cleanup_push(cleanup, NULL); // thread cleanup handler p
        thread_mutex_lock(&mutex);    
        pthread_cond_wait(&cond, &mutex);    
        pthread_mutex_unlock(&mutex);    
        pthread_cleanup_pop(0);    
        pthread_exit(NULL);
    }

## 参考博文: ##

1.  [取消线程及清理工作][Link 1]
2.  [线程终止的清理工作][Link 2]
3.  [一个 pthread\_cancel 引起的线程死锁][pthread_cancel]
4.  [取消点的进一步讨论][Link 3]
5.  [JAVA多线程相关介绍][JAVA]

[Link 1]: http://blog.sina.com.cn/s/blog_66fb0c830100y9hb.html
[Link 2]: http://www.cnblogs.com/mydomain/archive/2011/08/15/2139826.html
[pthread_cancel]: http://www.cnblogs.com/mydomain/archive/2011/08/15/2139830.html
[Link 3]: http://www.cnblogs.com/mydomain/archive/2011/08/15/2139850.html
[JAVA]: http://blog.sina.com.cn/s/blog_8da6362401013rcl.html