多此一举, C实现 try-catch
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了多此一举, C实现 try-catch相关的知识,希望对你有一定的参考价值。
在做NtyTcp的时候,有一些,就想用c来实现一套try-catch异常处理子系统。
不讨论C语言本身为什么不加try-catch,每个开发的朋友对于这个问题,都能说出一大堆的理由。
其实我也是不太喜欢强行在c中加入一个try-catch。就像把try-catch的原理跟自己的体会写出来。
首先我们来看看,try-catch的使用情景。
try { throw Excep; } catch (Excep) { } finally { }
try{ } 块是可能有异常的抛出的地方。throw Excep
catch (Excep) { } 是 捕获相应抛出异常的地方。
finally { } 是不论什么情形下,都是需要执行的代码块。
如果实现一套如此机制,有何实现的基础依赖。那就是setjmp与longjmp
讲到setjmp与longjmp,也是更说明一下
#include <setjmp.h> #include <stdio.h> jmp_buf env; int count = 0; void sub_func(int idx) { printf("sub_func --> idx:%d\n", idx); longjmp(env, idx); } int main(int argc, char *argv[]) { int idx = 0; if ((count = setjmp(env)) == 0) { printf("count:%d\n", count); sub_func(++idx); } else if (count == 1) { printf("count:%d\n", count); } { printf("other count\n"); } return 0; }
先来定义个
全局的jmp_buf env; 用来保存跳转的上下文。
int count = 0; 用来保存跳转返回值的。有点绕口,就是记录setjmp返回值的。
看到这里也许对setjmp与longjmp有点理解。再换个马甲,相信更有体会。
#include <setjmp.h> #include <stdio.h> jmp_buf env; int count = 0; #define Try if ((count = setjmp(env)) == 0) #define Catch(e) else if (count == (e)) #define Finally ; #define Throw(idx) longjmp(env, (idx)) void sub_func(int idx) { printf("sub_func --> idx:%d\n", idx); Throw(idx); } int main(int argc, char *argv[]) { int idx = 0; Try { printf("count:%d\n", count); sub_func(++idx); } Catch(1) { printf("count:%d\n", count); } Finally { printf("other count\n"); } return 0; }
try-catch就已经初具雏形了。这样只是基本实现,还有三个问题没有解决。
如何保证线程安全。
如何解决try-catch 嵌套。
如何避免,在不加try的代码块直接Throw。
如何保证线程安全。
使用线程的私有数据 pthread_key_t ,每一个线程都有一个try-catch的上下文环境。
如何解决try-catch嵌套的问题
使用一个栈式数据结构,每次try的时候压栈,每次throw的时候 出栈。
如何避免,在不加try的代码块直接Throw,
这个问题就比较好理解。既然每次try需要压栈,如果不加try,所以栈里面没有数据。在Throw之前先查看栈里面有没有数据。
那现在问题又来了,在pthread_key_t 与 链式栈如何结合? 先看如下结构体,也许会有新的认识,结构体里面有一个prev的域。
这样就能跟pthread_key_t 来结合,每次讲结构体指针保存在pthread_key_t中,获取完之后,拿到prev的值。
typedef struct _ntyExceptionFrame { jmp_buf env; int line; const char *func; const char *file; ntyException *exception; struct _ntyExceptionFrame *prev; char message[EXCEPTIN_MESSAGE_LENGTH+1]; } ntyExceptionFrame;
下面把整个实现代码都贴出来,大家也可以去我的github上面star,fork
/* * author : wangbojing * email : [email protected] * github : https://github.com/wangbojing */ #include <stdio.h> #include <string.h> #include <stdlib.h> #include <stdarg.h> #include <pthread.h> #include <setjmp.h> #define ntyThreadData pthread_key_t #define ntyThreadDataSet(key, value) pthread_setspecific((key), (value)) #define ntyThreadDataGet(key) pthread_getspecific((key)) #define ntyThreadDataCreate(key) pthread_key_create(&(key), NULL) #define EXCEPTIN_MESSAGE_LENGTH 512 typedef struct _ntyException { const char *name; } ntyException; ntyException SQLException = {"SQLException"}; ntyException TimeoutException = {"TimeoutException"}; ntyThreadData ExceptionStack; typedef struct _ntyExceptionFrame { jmp_buf env; int line; const char *func; const char *file; ntyException *exception; struct _ntyExceptionFrame *prev; char message[EXCEPTIN_MESSAGE_LENGTH+1]; } ntyExceptionFrame; #define ntyExceptionPopStack ntyThreadDataSet(ExceptionStack, ((ntyExceptionFrame*)ntyThreadDataGet(ExceptionStack))->prev) #define ReThrow ntyExceptionThrow(frame.exception, frame.func, frame.file, frame.line, NULL) #define Throw(e, cause, ...) ntyExceptionThrow(&(e), __func__, __FILE__, __LINE__, cause, ##__VA_ARGS__, NULL) enum { ExceptionEntered = 0, ExceptionThrown, ExceptionHandled, ExceptionFinalized }; #define Try do { volatile int Exception_flag; ntyExceptionFrame frame; frame.message[0] = 0; frame.prev = (ntyExceptionFrame*)ntyThreadDataGet(ExceptionStack); ntyThreadDataSet(ExceptionStack, &frame); Exception_flag = setjmp(frame.env); if (Exception_flag == ExceptionEntered) { #define Catch(e) if (Exception_flag == ExceptionEntered) ntyExceptionPopStack; } else if (frame.exception == &(e)) { Exception_flag = ExceptionHandled; #define Finally if (Exception_flag == ExceptionEntered) ntyExceptionPopStack; } { if (Exception_flag == ExceptionEntered) Exception_flag = ExceptionFinalized; #define EndTry if (Exception_flag == ExceptionEntered) ntyExceptionPopStack; } if (Exception_flag == ExceptionThrown) ReThrow; } while (0) static pthread_once_t once_control = PTHREAD_ONCE_INIT; static void init_once(void) { ntyThreadDataCreate(ExceptionStack); } void ntyExceptionInit(void) { pthread_once(&once_control, init_once); } void ntyExceptionThrow(ntyException *excep, const char *func, const char *file, int line, const char *cause, ...) { va_list ap; ntyExceptionFrame *frame = (ntyExceptionFrame*)ntyThreadDataGet(ExceptionStack); if (frame) { frame->exception = excep; frame->func = func; frame->file = file; frame->line = line; if (cause) { va_start(ap, cause); vsnprintf(frame->message, EXCEPTIN_MESSAGE_LENGTH, cause, ap); va_end(ap); } ntyExceptionPopStack; longjmp(frame->env, ExceptionThrown); } else if (cause) { char message[EXCEPTIN_MESSAGE_LENGTH+1]; va_start(ap, cause); vsnprintf(message, EXCEPTIN_MESSAGE_LENGTH, cause, ap); va_end(ap); printf("%s: %s\n raised in %s at %s:%d\n", excep->name, message, func ? func : "?", file ? file : "?", line); } else { printf("%s: %p\n raised in %s at %s:%d\n", excep->name, excep, func ? func : "?", file ? file : "?", line); } } /* ** **** ******** **************** debug **************** ******** **** ** */ ntyException A = {"AException"}; ntyException B = {"BException"}; ntyException C = {"CException"}; ntyException D = {"DException"}; void *thread(void *args) { pthread_t selfid = pthread_self(); Try { Throw(A, "A"); } Catch (A) { printf("catch A : %ld\n", selfid); } EndTry; Try { Throw(B, "B"); } Catch (B) { printf("catch B : %ld\n", selfid); } EndTry; Try { Throw(C, "C"); } Catch (C) { printf("catch C : %ld\n", selfid); } EndTry; Try { Throw(D, "D"); } Catch (D) { printf("catch D : %ld\n", selfid); } EndTry; Try { Throw(A, "A Again"); Throw(B, "B Again"); Throw(C, "C Again"); Throw(D, "D Again"); } Catch (A) { printf("catch A again : %ld\n", selfid); } Catch (B) { printf("catch B again : %ld\n", selfid); } Catch (C) { printf("catch C again : %ld\n", selfid); } Catch (D) { printf("catch B again : %ld\n", selfid); } EndTry; } #define THREADS 50 int main(void) { ntyExceptionInit(); Throw(D, NULL); Throw(C, "null C"); printf("\n\n=> Test1: Try-Catch\n"); Try { Try { Throw(B, "recall B"); } Catch (B) { printf("recall B \n"); } EndTry; Throw(A, NULL); } Catch(A) { printf("\tResult: Ok\n"); } EndTry; printf("=> Test1: Ok\n\n"); printf("=> Test2: Test Thread-safeness\n"); #if 1 int i = 0; pthread_t threads[THREADS]; for (i = 0;i < THREADS;i ++) { pthread_create(&threads[i], NULL, thread, NULL); } for (i = 0;i < THREADS;i ++) { pthread_join(threads[i], NULL); } #endif printf("=> Test2: Ok\n\n"); }
以上是关于多此一举, C实现 try-catch的主要内容,如果未能解决你的问题,请参考以下文章