c/c++ linux 进程间通信系列5，使用信号量

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了c/c++ linux 进程间通信系列5，使用信号量，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含8520字，纯文字阅读大概需要13分钟。

内容图文

linux 进程间通信系列5，使用信号量

int semget(key_t key, int num_sems, int sem_flags);

int semop(int sem_id, struct sembuf *sops, size_t nsops);

semops函数详细说明参考：semops

int semctl(int semid, int semnum, int cmd, ...);

下面的例子1创建了一个信号量的集合，可以用【ipcs -s】查看；例子2去访问例子1创建的信号量集合。

#include <stdio.h>
#include <string.h>
#include <sys/ipc.h>
#include <sys/sem.h>

#define NSEMS 16

int main(){
  int semid;
  unsigned short semun_array[NSEMS];
  int i;

  semid = semget(IPC_PRIVATE, NSEMS, 0600);
  if(semid < 0){
    perror("semget");
    return 1;
  }

  for(i =0; i < NSEMS; ++i){
    semun_array[i] = 1;
  }

  if(semctl(semid, 1000, SETALL, &semun_array) != 0){
    perror("semctl");
    return 1;
  }

  printf("semid:%d\n", semid);
  return 0;
}

github源代码

#include <stdio.h>
#include <string.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <stdlib.h>

#define NSEMS 16

int main(int argc, char* argv[]){
  int semid;
  sembuf sb;

  if(argc != 2){
    printf("arg is wrong\n");
    return 1;
  }

  semid = atoi(argv[1]);

  sb.sem_num = 15;//指定要操作的信号量是信号集合中的号码为0信号量
  sb.sem_op = -1;
  sb.sem_flg = SEM_UNDO;

  printf("before semop()\n");
  if(semop(semid, &sb, 1) != 0){
    perror("semop");
    return 1;
  }

  printf("after semop()\n");

  printf("press enter to exti\n");
  getchar();
  return 0;
}

github源代码

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <sys/types.h>
#include <sys/wait.h>

#define MYIPCKEY 0xabcdabcd
#define NSEMS 16

int sem_init(){
  int semid;
  unsigned short semun_array[NSEMS];
  sembuf sb[NSEMS];
  int i;

  semid = semget(MYIPCKEY, NSEMS, 0600 | IPC_CREAT | IPC_EXCL);
  if(semid >= 0){
    for(i = 0; i < NSEMS; ++i){
      semun_array[i] = 1;
    }
    if(semctl(semid, NSEMS, SETALL, &semun_array) != 0){
      perror("semctl");
      return 1;
    }
    printf("[pid:%d] new semaphore set, semid=%d\n", getpid(), semid);

    for(i = 0; i < NSEMS; ++i){
      sb[i].sem_num = i;
      sb[i].sem_op = -1;
      sb[i].sem_flg = SEM_UNDO;
    }

    printf("IF[pid:%d] before semop()\n", getpid());
    printf("IF[pid:%d] press enter to start semop()\n", getpid());
    getchar();

    if(semop(semid, sb, NSEMS)){
      perror("semop");
      return 1;
    }

    printf("IF[pid:%d] press enter to exit this process\n", getpid());
    getchar();

    exit(0);
  }
  else{
    if(errno != EEXIST){
      perror("semget");
      return 1;
    }
    else{
      printf("in else\n");
      semid_ds sds;
      semid = semget(MYIPCKEY, NSEMS, 0600);
      if(semid < 0){
    perror("semget 1");
    return 1;
      }

      printf("ELSE[pid:%d] before semctl()\n", getpid());

      while(true){
    //IPC_STAT的时候，忽略第二个参数
    if(semctl(semid, 0, IPC_STAT, &sds) != 0){
      perror("semctl 1");
      return 1;
    }
    printf("###########################\n");
    printf("sem_perm.mode:%d,sem_perm.__seq:%d\n",sds.sem_perm.mode,sds.sem_perm.__seq);
    printf("otime:%ld\n",sds.sem_otime);/* Last semop time */
    printf("ctime:%ld\n",sds.sem_ctime);/* Last change time */
    printf("sem_nsems:%ld\n",sds.sem_nsems);/* No. of semaphores in set */
    printf("###########################\n");
     
    if(sds.sem_otime != 0){
      break;
    }

    printf("ELSE[pid:%d] waiting otime change...\n", getpid());
    sleep(2);
      }


      sb[0].sem_num = 0;
      sb[0].sem_op = -1;
      sb[0].sem_flg = SEM_UNDO;
      
      sb[1].sem_num = 0;
      sb[1].sem_op = -1;
      sb[1].sem_flg = SEM_UNDO;

      printf("ELSE[pid:%d] before semop()\n", getpid());
      if(semop(semid, sb, 2) != 0){
    perror("semop 1");
    return 1;
      }

      printf("ELSE[pid:%d] after semop()\n", getpid());
    }
  }
  return 0;
}

int main(){
  pid_t pid;
  pid = fork();

  if(sem_init() < 0){
    printf("[pid:%d] sem_init() failed\n", getpid());
  }
}

github源代码

注意：执行一次后，再次执行前，必须用下面的命令删除信号量集合。

1，首先找到信号量集合的ID：

ipcs -s

2，删除信号量集合：

ipcrm -s id

内容总结

以上是互联网集市为您收集整理的c/c++ linux 进程间通信系列5，使用信号量全部内容，希望文章能够帮你解决c/c++ linux 进程间通信系列5，使用信号量所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端