在开发过程中,有三个独立执行的程序模块,三个模块都对sqlite数据库进行读写操作。sqlite在linux共享性较差,所以须要增加相互排斥信号量解决三个模块訪问数据库该问题。
另外,在增加信号量后,信号量sem初始化为1,假设三个模块随意一个在读或写数据库时ctrl+c掉(调试过程须要)。有时会造成信号量sem保持sem_wait后的值,也就是为0。这就造成了死锁。
为了解决上述情况,决定在某一个模块使用sem_timedwait(sem_t *sem,const struct timespec *abs_timeout)函数解决。
abs_timeout 指定一个堵塞的时间上限。假设调用因不能马上运行递减而要堵塞。abs_timeout 參数指向一个指定绝对超时时刻的结构,这个结果由自 Epoch,1970-01-01 00:00:00 +0000(UTC) 秒数和纳秒数构成。
通过一段时间对sem值的sem_timedwait。假设能使信号量-1,则证明信号量正常。再post该sem信号量。恢复sem。假设累计次数已到,仍然没有一次使信号量-1。则证明sem不正常,也就是为0。须要post该信号量,恢复sem。
详细的实现代码例如以下。此为截取的加入sem_timedwait的部分代码:
int i = 0; int result; int k=1; while(i < 100) { struct timespec ts; struct timeval tt; gettimeofday(&tt,NULL); ts.tv_sec = tt.tv_sec; ts.tv_nsec = tt.tv_usec*1000 + k * 1000 * 1000; ts.tv_sec += ts.tv_nsec/(1000 * 1000 *1000); ts.tv_nsec %= (1000 * 1000 *1000); result=sem_timedwait(sem,&ts); if(result==0) { sem_post(sem); break; } if(result==-1) { printf("errno value :%d ,it means %s\n",errno,strerror(errno)); printf("process iiii%d\n",i); } i++; k++; } if(i==100) { sem_post(sem); } printf("sem time wait over\n");