《unix高级环境编程》线程控制——线程取消选项-蒲公英云

《unix高级环境编程》线程控制——线程取消选项

梦里梦外; 2022-08-14 00:42 330阅读 0赞

线程的取消选项有两种：可取消状态、可取消类型。这两个属性影响 pthread_cancel 函数的工作。

可取消状态

可取消状态属性有两种状态，分别为 PTHREAD_CANCEL_ENABLE (默认) 和 PTHREAD_CANCEL_DISABLE。线程可以通过以下函数修改可取消状态：

/* 线程取消选项 */
/*
 * 函数功能：修改可取消状态属性；
 * 返回值：若成功则返回0，否则返回错误编码；
 * 函数原型：
 */
#include <pthread.h>
int pthread_setcancelstate(int state, int *oldstate);
/*
 * 说明：
 * 该函数把可取消状态设置为state，把旧的可取消状态存放在oldstate所指的内存单元中；
 */
/*
 * 函数功能：添加线程的取消点；
 * 无返回值；
 * 函数原型：
 */
#include <pthread.h>
void pthread_testcancel(void);
/*
 * 说明：
 * 调用该函数时，若有某个取消请求处于未决状态，而且取消并没有置为无效，
 * 则线程就会被取消；但是若取消置为无效，则该函数调用没有任何效果；
 */

可取消类型

可取消类型属性有两种类型，分别为 PTHREAD_CANCEL_DEFERRED (延时取消) 和 PTHREAD_CANCEL_ASYNCHRONOUS(异步取消)。线程可以通过以下函数修改可取消类型：

/*
 * 函数功能：修改取消类型；
 * 返回值：若成功则返回0，否则返回错误编码；
 * 函数原型：
 */
#include <pthread.h>
int pthread_setcanceltype(int type, int *oldtype);

测试程序：

#include "apue.h"
#include <pthread.h>
static void *fun1(void *arg);
static void *fun2(void *arg);
pthread_t tid1, tid2;
int err;
int main(void)
{
    err = pthread_create(&tid1, NULL, fun1, NULL);
    if(err != 0)
        err_quit("can't create thread: %s\n", strerror(err));
    err = pthread_create(&tid2, NULL, fun2, NULL);
    if(err != 0)
        err_quit("can't create thread: %s\n", strerror(err));
    err = pthread_detach(tid1);
    if(err != 0)
        err_quit("detach error: %s\n", strerror(err));
    err = pthread_detach(tid2);
    if(err != 0)
        err_quit("detach error: %s\n", strerror(err));
    exit(0);
}
static void *fun1(void *arg)
{
    err = pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL);
    if(err != 0)
        err_quit("set state error: %s\n", strerror(err));
    printf("thread 1 starting...\n");
    sleep(15);
    printf("thread 1 returnting...\n");
    err = pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
    if(err != 0)
        err_quit("set state error: %s\n", strerror(err));
    printf("thread 1.2 starting...\n");
    pthread_testcancel();
    printf("thread 1.2 returnting...\n");
    pthread_exit((void*)0);
}
static void *fun2(void *arg)
{
    printf("thread 2 starting...\n");
    err = pthread_cancel(tid1);
    if(err != 0)
        err_quit("can't cancel thread 1: %s\n", strerror(err));
    printf("thread 2 returnting...\n");
    pthread_exit((void*)0);
}