linux 进程间信号量管理程序之sem_timedwait使用

标签：sqlite   互斥信号量   数据库   

在开发过程中，有三个独立运行的程序模块，三个模块都对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");

linux 进程间信号量管理程序之sem_timedwait使用,布布扣,bubuko.com

linux 进程间信号量管理程序之sem_timedwait使用

标签：sqlite   互斥信号量   数据库   

原文地址：http://blog.csdn.net/guofu8241260/article/details/32089951