posix信号量sem_wait死锁解决方法
2015-05-06 10:58
393 查看
在开发过程中,有三个独立运行的程序模块,三个模块都对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的部分代码:
[cpp]
view plaincopyprint?
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");
为了解决上述情况,决定在某一个模块使用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的部分代码:
[cpp]
view plaincopyprint?
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");
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");
相关文章推荐
- linux下生产者与消费者问题代码,以及编译c代码时error:undefined reference to sem_wait 解决方法之一
- 产生死锁的必要条件以及解决的方法
- sqlserver高并发情况下 select 和update操作造成死锁的解决方法
- 解决linux下大量TIME WAIT的方法详解
- sem_init,sem_post,sem_wait 信号量的用法解释
- [转] MySQL死锁问题分析及解决方法实例详解
- 产生死锁的原因和必要条件+解决死锁的基本方法
- 数据库服务器死锁的解决方法
- 进程死锁的危害、导致原因、解决方法【转载】
- 信号量 sem_timedwait 函数的使用
- 产生死锁的原因和必要条件+解决死锁的基本方法
- MySQL死锁问题实例分析及解决方法
- 产生死锁的原因和必要条件+解决死锁的基本方法
- 死锁原因,解决,避免方法及哲学家就餐问题
- linux 进程间信号量管理程序之sem_timedwait使用
- TCP短连接产生大量TIME_WAIT导致无法对外建立新TCP连接的原因及解决方法—基础知识篇
- TCP: time wait bucket table overflow的解决方法
- android发送模拟按键消息,出现死锁,timeout的解决方法
- SQL Server中解决死锁的新方法介绍和C#中多线程避免并发
- linux服务器出现大量TIME_WAIT的解决方法