今天學(xué)習(xí)skynet_monitor。

skynet_monitor主要用于監(jiān)測skynet_context在處理消息時(shí)是否陷入死循環(huán)。

struct skynet_monitor;struct skynet_monitor * skynet_monitor_new();//新建一個(gè)監(jiān)視器void skynet_monitor_delete(struct skynet_monitor *);//刪除一個(gè)監(jiān)視器void skynet_monitor_trigger(struct skynet_monitor *, uint32_t source, uint32_t destination);//通知監(jiān)視器開始void skynet_monitor_check(struct skynet_monitor *);//檢查監(jiān)視器是否陷入死循環(huán)skynet啟動時(shí)會為每個(gè)工作線程創(chuàng)建一個(gè)對應(yīng)的監(jiān)視器：
static voidstart(int thread) {	pthread_t pid[thread+3];	struct monitor *m = skynet_malloc(sizeof(*m));	memset(m, 0, sizeof(*m));	m->count = thread;	m->sleep = 0;	m->m = skynet_malloc(thread * sizeof(struct skynet_monitor *));	int i;	for (i=0;i<thread;i++) {		m->m[i] = skynet_monitor_new();//創(chuàng)建監(jiān)視器	}        ......然后，sc在處理消息時(shí)，會調(diào)用skynet_monitor_trigger：
struct message_queue * skynet_context_message_dispatch(struct skynet_monitor *sm, struct message_queue *q, int weight) {	......        ......	for (i=0;i<n;i++) {		......                ......		skynet_monitor_trigger(sm, msg.source , handle);//開始監(jiān)視		if (ctx->cb == NULL) {			skynet_free(msg.data);		} else {			dispatch_message(ctx, &msg);//處理消息		}		skynet_monitor_trigger(sm, 0,0);//結(jié)束監(jiān)視	}	......	return q;}監(jiān)視的驅(qū)動是由一個(gè)單獨(dú)的線程來做的：
static void *thread_monitor(void *p) {	struct monitor * m = p;	int i;	int n = m->count;	skynet_initthread(THREAD_MONITOR);	for (;;) {		CHECK_ABORT		for (i=0;i<n;i++) {			skynet_monitor_check(m->m[i]);		}		for (i=0;i<5;i++) {			CHECK_ABORT			sleep(1);		}	}	return NULL;}從這里可以看出，5秒不退出，就認(rèn)為死循環(huán)成立。
當(dāng)然處理方案也只是打印了一個(gè)日志罷了。