分类： LINUX
2013-11-18 21:12:32
信号量函数由semget、semop、semctl三个函数组成。下面的表格列出了这三个函数的函数原型及具体说明。
|
semget(得到一个信号量集标识符或创建一个信号量集对象) |
||
|
所需头文件 |
#include
#include
#include |
|
|
函数说明 |
得到一个信号量集标识符或创建一个信号量集对象并返回信号量集标识符 |
|
|
函数原型 |
int semget(key_t key, int nsems, int semflg) |
|
|
函数传入值 |
key |
0(IPC_PRIVATE)：会建立新信号量集对象 |
|
大于0的32位整数：视参数semflg来确定操作，通常要求此值来源于ftok返回的IPC键值 |
||
|
nsems |
创建信号量集中信号量的个数，该参数只在创建信号量集时有效 |
|
|
msgflg |
0：取信号量集标识符，若不存在则函数会报错 |
|
|
IPC_CREAT：当semflg&IPC_CREAT为真时，如果内核中不存在键值与key相等的信号量集，则新建一个信号量集；如果存在这样的信号量集，返回此信号量集的标识符 |
||
|
IPC_CREAT|IPC_EXCL：如果内核中不存在键值与key相等的信号量集，则新建一个消息队列；如果存在这样的信号量集则报错 |
||
|
函数返回值 |
成功：返回信号量集的标识符 |
|
|
出错：-1，错误原因存于error中 |
||
|
附加说明 |
上述semflg参数为模式标志参数，使用时需要与IPC对象存取权限（如0600）进行|运算来确定信号量集的存取权限 |
|
|
错误代码 |
EACCESS：没有权限 EEXIST：信号量集已经存在，无法创建 EIDRM：信号量集已经删除 ENOENT：信号量集不存在，同时semflg没有设置IPC_CREAT标志 ENOMEM：没有足够的内存创建新的信号量集 ENOSPC：超出限制 |
|
如果用semget创建了一个新的信号量集对象时，则semid_ds结构成员变量的值设置如下：
? sem_otime设置为0。
? sem_ctime设置为当前时间。
? msg_qbytes设成系统的限制值。
? sem_nsems设置为nsems参数的数值。
? semflg的读写权限写入sem_perm.mode中。
? sem_perm结构的uid和cuid成员被设置成当前进程的有效用户ID，gid和cuid成员被设置成当前进程的有效组ID。
|
semop(完成对信号量的P操作或V操作) |
|
|
所需头文件 |
#include
#include
#include |
|
函数说明 |
对信号量集标识符为semid中的一个或多个信号量进行P操作或V操作 |
|
函数原型 |
int semop(int semid, struct sembuf *sops, unsigned nsops) |
|
函数传入值 |
semid：信号量集标识符 |
|
sops：指向进行操作的信号量集结构体数组的首地址，此结构的具体说明如下： struct sembuf { short semnum; /*信号量集合中的信号量编号，0代表第1个信号量*/ short val;/*若val>0进行V操作信号量值加val，表示进程释放控制的资源 */ /*若val<0进行P操作信号量值减val，若(semval-val)<0（semval为该信号量值），则调用进程阻塞，直到资源可用；若设置IPC_NOWAIT不会睡眠，进程直接返回EAGAIN错误*/ /*若val==0时阻塞等待信号量为0，调用进程进入睡眠状态，直到信号值为0；若设置IPC_NOWAIT，进程不会睡眠，直接返回EAGAIN错误*/ short flag; /*0 设置信号量的默认操作*/ /*IPC_NOWAIT设置信号量操作不等待*/ /*SEM_UNDO 选项会让内核记录一个与调用进程相关的UNDO记录，如果该进程崩溃，则根据这个进程的UNDO记录自动恢复相应信号量的计数值*/ }; |
|
|
nsops：进行操作信号量的个数，即sops结构变量的个数，需大于或等于1。最常见设置此值等于1，只完成对一个信号量的操作 |
|
|
函数返回值 |
成功：返回信号量集的标识符 |
|
出错：-1，错误原因存于error中 |
|
|
错误代码 |
E2BIG：一次对信号量个数的操作超过了系统限制 EACCESS：权限不够 EAGAIN：使用了IPC_NOWAIT，但操作不能继续进行 EFAULT：sops指向的地址无效 EIDRM：信号量集已经删除 EINTR：当睡眠时接收到其他信号 EINVAL：信号量集不存在,或者semid无效 ENOMEM：使用了SEM_UNDO，但无足够的内存创建所需的数据结构 ERANGE：信号量值超出范围 |
sops为指向sembuf数组，定义所要进行的操作序列。下面是信号量操作举例。
struct sembuf sem_get={0,-1,IPC_NOWAIT}; /*将信号量对象中序号为0的信号量减1*/
struct sembuf sem_get={0,1,IPC_NOWAIT}; /*将信号量对象中序号为0的信号量加1*/
struct sembuf sem_get={0,0,0}; /*进程被阻塞，直到对应的信号量值为0*/
flag一般为0，若flag包含IPC_NOWAIT，则该操作为非阻塞操作。若flag包含SEM_UNDO，则当进程退出的时候会还原该进程的信号量操作，这个标志在某些情况下是很有用的，比如某进程做了P操作得到资源，但还没来得及做V操作时就异常退出了，此时，其他进程就只能都阻塞在P操作上，于是造成了死锁。若采取SEM_UNDO标志，就可以避免因为进程异常退出而造成的死锁。
|
semctl (得到一个信号量集标识符或创建一个信号量集对象) |
||
|
所需头文件 |
#include
#include
#include |
|
|
函数说明 |
得到一个信号量集标识符或创建一个信号量集对象并返回信号量集标识符 |
|
|
函数原型 |
int semctl(int semid, int semnum, int cmd, union semun arg) |
|
|
函数传入值 |
semid |
信号量集标识符 |
|
semnum |
信号量集数组上的下标，表示某一个信号量 |
|
|
cmd |
见下文表15-4 |
|
|
arg |
union semun { short val; /*SETVAL用的值*/ struct semid_ds* buf; /*IPC_STAT、IPC_SET用的semid_ds结构*/ unsigned short* array; /*SETALL、GETALL用的数组值*/ struct seminfo *buf; /*为控制IPC_INFO提供的缓存*/ } arg; |
|
|
函数返回值 |
成功：大于或等于0，具体说明请参照表15-4 |
|
|
出错：-1，错误原因存于error中 |
||
|
附加说明 |
semid_ds结构见上文信号量集内核结构定义 |
|
|
错误代码 |
EACCESS：权限不够 EFAULT：arg指向的地址无效 EIDRM：信号量集已经删除 EINVAL：信号量集不存在，或者semid无效 EPERM：进程有效用户没有cmd的权限 ERANGE：信号量值超出范围 |
|
表15-4 semctl函数cmd形参说明表
|
命令 |
解 释 |
|
IPC_STAT |
从信号量集上检索semid_ds结构，并存到semun联合体参数的成员buf的地址中 |
|
IPC_SET |
设置一个信号量集合的semid_ds结构中ipc_perm域的值，并从semun的buf中取出值 |
|
IPC_RMID |
从内核中删除信号量集合 |
|
GETALL |
从信号量集合中获得所有信号量的值，并把其整数值存到semun联合体成员的一个指针数组中 |
|
GETNCNT |
返回当前等待资源的进程个数 |
|
GETPID |
返回最后一个执行系统调用semop()进程的PID |
|
GETVAL |
返回信号量集合内单个信号量的值 |
|
GETZCNT |
返回当前等待100%资源利用的进程个数 |
|
SETALL |
与GETALL正好相反 |
|
SETVAL |
用联合体中val成员的值设置信号量集合中单个信号量的值 |
4. 信号量应用程序举例
sem.c源代码如下：
#include
#include
#include
#include
union semun {
int val; /* value for SETVAL */
struct semid_ds *buf; /* buffer for IPC_STAT, IPC_SET */
unsigned short *array; /* array for GETALL, SETALL */
struct seminfo *__buf; /* buffer for IPC_INFO */
};
/***对信号量数组semnum编号的信号量做P操作***/
int P(int semid, int semnum)
{
struct sembuf sops={semnum,-1, SEM_UNDO};
return (semop(semid,&sops,1));
}
/***对信号量数组semnum编号的信号量做V操作***/
int V(int semid, int semnum)
{
struct sembuf sops={semnum,+1, SEM_UNDO};
return (semop(semid,&sops,1));
}
int main(int argc, char **argv)
{
int key ;
int semid,ret;
union semun arg;
struct sembuf semop;
int flag ;
key = ftok("/tmp", 0x66 ) ;
if ( key < 0 )
{
perror("ftok key error") ;
return -1 ;
}
/***本程序创建了三个信号量，实际使用时只用了一个0号信号量***/
semid = semget(key,3,IPC_CREAT|0600);
if (semid == -1)
{
perror("create semget error");
return ;
}
if ( argc == 1 )
{
arg.val = 1;
/***对0号信号量设置初始值***/
ret =semctl(semid,0,SETVAL,arg);
if (ret < 0 )
{
perror("ctl sem error");
semctl(semid,0,IPC_RMID,arg);
return -1 ;
}
}
/***取0号信号量的值***/
ret =semctl(semid,0,GETVAL,arg);
printf("after semctl setval sem[0].val =[%d]\n",ret);
system("date") ;
printf("P operate begin\n") ;
flag = P(semid,0) ;
if ( flag )
{
perror("P operate error") ;
return -1 ;
}
printf("P operate end\n") ;
ret =semctl(semid,0,GETVAL,arg);
printf("after P sem[0].val=[%d]\n",ret);
system("date") ;
if ( argc == 1 )
{
sleep(120) ;
}
printf("V operate begin\n") ;
if (V(semid, 0) < 0)
{
perror("V operate error") ;
return -1 ;
}
printf("V operate end\n") ;
ret =semctl(semid,0,GETVAL,arg);
printf("after V sem[0].val=%d\n",ret);
system("date") ;
if ( argc >1 )
{
semctl(semid,0,IPC_RMID,arg);
}
return 0 ;
}
