信号量应用

  1. #include <linux/sem.h> 
  2.  
  3. #include <stdio.h> 
  4.  
  5. #include <errno.h> 
  6.  
  7. #define SEM_PATH "/home/my_sem" 
  8.  
  9. #define max_tries 3  
  10.  
  11.  
  12.  
  13. int semid; 
  14.  
  15. main() 
  16.  
  17. { 
  18.  
  19. int flag1,flag2,key,i,init_ok,tmperrno; 
  20.  
  21. struct semid_ds sem_info; 
  22.  
  23. struct seminfo sem_info2; 
  24.  
  25. union semun arg;    //union semun£º Çë²Î¿ŒžœÂŒ2 
  26.  
  27. struct sembuf askfor_res, free_res; 
  28.  
  29. flag1=IPC_CREAT|IPC_EXCL|00666; 
  30.  
  31. flag2=IPC_CREAT|00666; 
  32.  
  33. key=ftok(SEM_PATH,'a'); 
  34.  
  35. //error handling for ftok here; 
  36.  
  37. init_ok=0; 
  38.  
  39. semid=semget(key,1,flag1);//create a semaphore set that only includes one semphore. 
  40.  
  41. if(semid<0) 
  42.  
  43. { 
  44.  
  45.  tmperrno=errno; 
  46.  
  47.  perror("semget"); 
  48.  
  49. if(tmperrno==EEXIST) 
  50.  
  51. //errno is undefined after a successful library call( including perror call) so it is saved //in tmperrno. 
  52.  
  53.   { 
  54.  
  55.   semid=semget(key,1,flag2); 
  56.  
  57. //flag2 Ö»°üº¬ÁËIPC_CREAT±êÖŸ, ²ÎÊýnsems(ÕâÀïΪ1)±ØÐëÓëÔ­ÀŽµÄÐźŵÆÊýÄ¿Ò»Ö 
  58.  
  59.   arg.buf=&sem_info; 
  60.  
  61.   for(i=0; i<max_tries; i++) 
  62.  
  63.   { 
  64.  
  65.    if(semctl(semid, 0, IPC_STAT, arg)==-1) 
  66.  
  67.    { perror("semctl error"); i=max_tries;} 
  68.  
  69.    else 
  70.  
  71.    {  
  72.  
  73.     if(arg.buf->sem_otime!=0){ i=max_tries;  init_ok=1;} 
  74.  
  75.     else  sleep(1);  
  76.  
  77.    } 
  78.  
  79.   } 
  80.  
  81.   if(!init_ok) 
  82.  
  83.   // do some initializing, here we assume that the first process that creates the sem will  
  84.  
  85.   // finish initialize the sem and run semop in max_tries*1 seconds. else it will not run  
  86.  
  87.   // semop any more. 
  88.  
  89.   { 
  90.  
  91.    arg.val=1; 
  92.  
  93.    if(semctl(semid,0,SETVAL,arg)==-1) perror("semctl setval error"); 
  94.  
  95.   }  
  96.  
  97.  } 
  98.  
  99.  else 
  100.  
  101.  {perror("semget error, process exit");  
  102.  
  103.  exit(1);  
  104.  
  105.  } 
  106.  
  107. } 
  108.  
  109. else //semid>=0; do some initializing   
  110.  
  111. { 
  112.  
  113.  arg.val=1; 
  114.  
  115.  if(semctl(semid,0,SETVAL,arg)==-1) 
  116.  
  117.   perror("semctl setval error"); 
  118.  
  119. } 
  120.  
  121. //get some information about the semaphore and the limit of semaphore in redhat8.0 
  122.  
  123.  arg.buf=&sem_info; 
  124.  
  125.  if(semctl(semid, 0, IPC_STAT, arg)==-1) 
  126.  
  127.   perror("semctl IPC STAT");   
  128.  
  129.  printf("owner's uid is %d
",  arg.buf->sem_perm.uid); 
  130.  
  131.  printf("owner's gid is %d
",  arg.buf->sem_perm.gid); 
  132.  
  133.  printf("creater's uid is %d
",  arg.buf->sem_perm.cuid); 
  134.  
  135.  printf("creater's gid is %d
",  arg.buf->sem_perm.cgid); 
  136.  
  137.  
  138.  
  139.  arg.__buf=&sem_info2; 
  140.  
  141.  if(semctl(semid,0,IPC_INFO,arg)==-1) 
  142.  
  143.   perror("semctl IPC_INFO"); 
  144.  
  145.  printf("the number of entries in semaphore map is %d 
",    arg.__buf->semmap); 
  146.  
  147.  printf("max number of semaphore identifiers is %d 
",     arg.__buf->semmni); 
  148.  
  149.  printf("mas number of semaphores in system is %d 
",     arg.__buf->semmns); 
  150.  
  151.  printf("the number of undo structures system wide is %d 
",   arg.__buf->semmnu); 
  152.  
  153.  printf("max number of semaphores per semid is %d 
",     arg.__buf->semmsl); 
  154.  
  155.  printf("max number of ops per semop call is %d 
",     arg.__buf->semopm); 
  156.  
  157.  printf("max number of undo entries per process is %d 
",     arg.__buf->semume); 
  158.  
  159.  printf("the sizeof of struct sem_undo is %d 
",         arg.__buf->semusz); 
  160.  
  161.  printf("the maximum semaphore value is %d 
",      arg.__buf->semvmx); 
  162.  
  163.   
  164.  
  165. //now ask for available resource:  
  166.  
  167.  askfor_res.sem_num=0; 
  168.  
  169.  askfor_res.sem_op=-1; 
  170.  
  171.  askfor_res.sem_flg=SEM_UNDO;   
  172.  
  173.    
  174.  
  175.   if(semop(semid,&askfor_res,1)==-1)//ask for resource 
  176.  
  177.    perror("semop error"); 
  178.  
  179.   
  180.  
  181.  sleep(3); //do some handling on the sharing resource here, just sleep on it 3 seconds 
  182.  
  183.  printf("now free the resource
");  
  184.  
  185.   
  186.  
  187. //now free resource  
  188.  
  189.  free_res.sem_num=0; 
  190.  
  191.  free_res.sem_op=1; 
  192.  
  193.  free_res.sem_flg=SEM_UNDO; 
  194.  
  195.  
  196.  
  197.  if(semop(semid,&free_res,1)==-1)//free the resource. 
  198.  
  199.   if(errno==EIDRM) 
  200.  
  201.    printf("the semaphore set was removed
"); 
  202.  
  203. //you can comment out the codes below to compile a different version:    
  204.  
  205.  if(semctl(semid, 0, IPC_RMID)==-1) 
  206.  
  207.   perror("semctl IPC_RMID"); 
  208.  
  209.  else printf("remove sem ok
"); 
  210.  
  211. } 

本文出自 “阿凡达” 博客，请务必保留此出处http://shamrock.blog.51cto.com/2079212/725028

【推广】 免费学中医，健康全家人
原文地址：https://www.cnblogs.com/umgsai/p/3908220.html