多线程编程原理与实战（超优秀）

多线程编程-监控线程

1、监控线程概述...............................................................................................................................1

2、需求...............................................................................................................................................1

3、示例...............................................................................................................................................1

4、相关文献.....................................................................................................................................10

1、监控线程概述

不死线程常见于进程中的关键线程，即进程内其它线程的正常运行依赖于该线程，比

如在网络编程中，负责与其它模块通信的 socket 线程等。如何保证关键线程始终运行，常

3、示例

/*

* 作者: Jeffrey.zhu

* 功能: 线程监控示例

* 日期: 2010 年 6 月

* 联系方式: 墨客论文网: http://www.mowker.com

* CSDN

博客 ：http://blog.csdn.net/gueter/

*/

#include <sys/ipc.h>

#include <semaphore.h>

/* 线程触发标志 */

enum {

PTHREAD_ID_NONE = -1, /* 未知状态 */

PTHREAD_ID_INIT = 0, /* 初始状态触发 */

PTHREAD_ID1 = 1, /* 线程 1 触发 */

PTHREAD_ID2 = 2, /* 线程 2 触发 */

};

enum {

OK = 0, /* 成功 */

};

static int start_pthread_flag = PTHREAD_ID_INIT; /* 触发线程标志 */

static int pthread1_exit_flag = PTHREAD_FLAG_ON; /* pthread1 退出标志 */

static int pthread2_exit_flag = PTHREAD_FLAG_ON; /* pthread2 退出标志 */

/* 线程属性及 ID */

static pthread_attr_t pthreads_attr;

static pthread_t tmp_id = PTHREAD_ID_INIT;

static pthread_t pthread1_id = PTHREAD_ID_INIT;

static pthread_t pthread2_id = PTHREAD_ID_INIT;

/* 接口声明 */

static void pthread1(void *arg);

static void pthread2(void *arg);

static void pthread1_exit(void);

static void pthread2_exit(void);

static int pthreads_init(void);

static void pthreads_deinit(void);

/*

* 作者: Jeffrey.zhu

* 功能: 主线程为监控线程

* 联系方式: 墨客论文网: http://www.mowker.com

* CSDN

博客 ：http://blog.csdn.net/gueter/

*/

perror("sem_init");

/* 启动 pthread1 子线程 */

if (pthread1_exit_flag == PTHREAD_FLAG_ON) {

/* 判断触发者 */

if ((PTHREAD_ID_INIT == start_pthread_flag) ||

(PTHREAD_ID1 == start_pthread_flag)) {

pthreads_deinit(); /* 首次先 deinit */

res = pthreads_init();

while (ERROR == res) { /* 确保初始化成功 */

fprintf(stderr, "pthread init failure, reinit\n");