【C语言_文件_进程_进程间通讯 常用函数/命令 + 实例】.md_update:23/10/27

这篇具有很好参考价值的文章主要介绍了【C语言_文件_进程_进程间通讯 常用函数/命令 + 实例】.md_update:23/10/27。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

文件相关命令

ps -aux|grep init?      //搜索包含init名称的进程
top                     //linux下的资源管理器(动态)

//open 返回的int 是给后面的读/写/光标移动 用的fd,没有open就不能进行后面的操作;
int open(const char *pathname, int flags);
int open(const char *pathname, int flags, mode_t mode);
close(fd); //关闭文件

// _t 都是返回的int数字;写write,读read,光标移动lseek
ssize_t write(int fd, const void *buf, size_t count);
ssize_t read(int fd, void *buf, size_t count);

vimdiff demo1.c demo2.c 

//fopen注意mode就行,有:r r+ w w+ a ,返回的文件指针是给后面的读 写 偏移用
FILE *fopen(const char *pathname, const char *mode);
fclose(FILE *); //关闭文件

//跟上面的差不多一样用
//fread/fwrite(读写的数组,读写的大小,  读写的最大次数?, 读写的文件指针)
                (读写返回次数的区别:读为有效次数,能一次读完就算你写10次,也返回只读1次)
size_t fread(void *ptr, size_t size, size_t nmemb, FILE *stream);
size_t fwrite(const void *ptr, size_t size, size_t nmemb,FILE *stream);
int fseek(FILE *stream, long offset, int whence);

fputc();//写入一个字符;
fgetc();//读取一个字符
feof();/检测是否到达文件末尾,到了返回1;文件结束符为EOF=-1;

//注意:读写操作都会使光标偏移,但也可以利用这点来遍历读写文件;
例:
while(!feof(FILE* fd)){
        printf("%c  ",fgetc(FILE* fd));

进程相关命令

getpid(); fork(); vfork();

//_t 一律返回的是int
//获取进程ID 就是pid
pid_t getpid(void);

//fork创建子进程
pid_t fork(void);
//这里返回的是的pid = 0 就是子进程,pid > 0 就是父进程;
//所以可以通过判断pid的值,来区别父子进程需要执行的代码;
//注意fork开辟的子进程,没有等待一说,父子进程谁抢到就先运行谁,
//【子进程为僵尸进程】;
//例:

    #include<stdio.h>
    #include <sys/types.h>
    #include <unistd.h>
    #include <stdlib.h>
    int main()
    {
            pid_t pid;

            int num = 0;
            pid = getpid();
            printf("this pid:%d\n",getpid());


            pid_t return_pid = fork();

            if(return_pid > 0){
                    while(1){
                    printf("this father pid:%d return_pid:%d \n",getpid(),return_pid);
                    printf("father now num:%d\n",num);
                    sleep(1);
                    }

            }else if(return_pid == 0){

                    printf("this son pid:%d return_pid:%d \n",getpid(),return_pid);
                    num += 2;
                    printf("child now num:%d\n",num);
                    exit(6);
            }
    }

//vfork创建子进程
pid_t vfork(void);
//注意fork开辟的子进程,会等待子进程执行完并exit(num)后,父子进程才继续执行,
//【子进程不会成为僵尸进程】;
//例:

    #include<stdio.h>
    #include <sys/types.h>
    #include <unistd.h>
    #include <stdlib.h>
    int main()
    {
            pid_t pid;
            pid = getpid();
            printf("this pid:%d\n",getpid());
            int num = 0;
            printf("start_father_num:%d \n",num);
            pid_t return_pid = vfork();
            if(return_pid > 0){
                    while(1){
                            printf("this father pid:%d return_pid:%d \n",getpid(),return_pid);
                            printf("num = %d\n",num);
                            sleep(1);
                    }
            }
            else if(return_pid == 0){
                    int i;
                    for(i=0;i<3;i++){
                            printf("this son pid:%d return_pid:%d \n",getpid(),return_pid);
                            num++;
                            sleep(1);
                    }
                    exit(0);
            }
            return 0;
    }

exit(6);wait(status); WEXITSTATUS(status);

//wait() 返回的是子进程的ID 即pid;
//里面的 int *status 是子进程的exit(num)的num码;
//后续使用WEXITSTATUS(status),即可打印出来子进程退出时的状态码;
pid_t wait(int *status);
//例:

    #include <stdio.h>
    #include <sys/types.h>
    #include <unistd.h>
    #include <stdlib.h>
    int main()
    {
            pid_t pid;
            int status = 0;
            pid = getpid();
            printf("start father pid:%d\n",getpid());
            pid_t return_pid = fork();
            if(return_pid > 0 ){
                    pid_t child_pid = wait(&status);
                    printf("\n\nwait_return_childe_pid:%d\n",child_pid);
                    printf("child exit code:%d \n",WEXITSTATUS(status));
                    while(1){
                    printf("this father pid:%d fork_return_pid:%d > 0  \n",getpid(),return_pid);
                    sleep(1);
                    }
                    }else if(return_pid == 0){
                            int i;
                            for(i=0;i<3;i++){
                                    printf("this son pid:%d fork_return_pid:%d == 0 \n",getpid(),return_pid);
                            }
                            exit (6);
                    }



            return 0;
    }

exec组函数 对比 system + popen :

精彩博文参照:
https://blog.csdn.net/u014530704/article/details/73848573

观后感:

跟着execl/execlp指定的程序跑了,不回来了!

//  date 获取时间的程序
execl("./PATH","date","NULL");
//  execl(程序所在路径,程序名,结尾必须为NULL)
//  就像这样用,在当前程序运行到这句代码时,
//  便将替换为后续执行execl所指的程序,不带回头的那种!

execlp("date","date",NULL);
//  execlp(程序名,程序名,结尾必须为NULL)
//  就像这样用,它带p,能自己在环境变量下搜索对应的程序并替换后续执行;
//  也是不带回头的那种!

相比较之下 system 执行完指定程序后,还会回来,挺好!

system("cat demo1.c");
//执行完成后返回原程序,继续执行后续代码;

而对比popen 而言,popen除了将指定程序/代码执行完之后,继续执行后续代码外,还将读/写的内容放在管道内,并以文件指针的形式返回;

    #include <stdio.h>
    #include <unistd.h>
    int main()
    {
            printf("------------------------------------------------\nPS:\n");

            char* p = "ps";
            FILE *fd = popen(p,"r");
            char data[1024];
            fread(&data,1024,1,fd);
            printf("%s\n",data);
            perror("why");
            return 0;
    }

进程间通讯

精彩博文参照

观后感:

pipe 无名管道

int pipe(int pipefd[2]); (无名管道,在文件里看不到)

里面的fd[2]数组,其中 fd[0] : 读的fd, fd[1] : 写的fd;

//例:通过在父子进程中 close (fd[0]/fd[1]) 配合read(); write(); 实现进程间通讯;

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
int main()
{
        printf("------------------------------------------------:\n");
        int fd[2];
        int n_pipe = pipe(fd);

        char data1[128];
        if(n_pipe < 0){
                printf("error: can not creat pipe!\n");
                perror("why");
        }

        int pid = fork();
        if(pid < 0){
                printf("error: creat child failed!\n");
                perror("why");
        }
        if(pid > 0){
                // sleep(2);
                printf("this is father pc\n");
                close(fd[0]);
                write(fd[1],"hello pipe from father;",strlen("hello pipe from father;"));
                close(fd[1]);
        }
        if(pid == 0){
                printf("this is child pc\n");
                close(fd[1]);
                read(fd[0],data1,128);
                printf("data : %s\n",data1);
                exit(9);
                }
        return 0;
}

mkfifo 有名管道

//成功返回0;失败返回-1 设置erron = -1;
//返回值判断报错值:EEXIST,可以锁定报错为同名文件已存在目录中;
int mkfifo(const char *pathname, mode_t mode);
RETURN VALUE
On success mkfifo() and mkfifoat() return 0. In the case of
an error, -1 is returned (in which case, errno is set appro‐
priately).
EEXIST pathname already exists. This includes the case where
pathname is a symbolic link, dangling or not.

//例:

    #include<stdio.h>
    #include <errno.h>
    #include <sys/types.h>
    #include <sys/stat.h>
    int main()
    {
            if(mkfifo("./demo1.txt",0666) < 0 && errno == EEXIST ){
            printf("mkfifo error:\n");
            perror("why");
    }
    return 0;
    }

//mkfifo 配合 open read write 完成管道通讯;
//demo mkread:

    #include<stdio.h>
    #include <errno.h>
    #include <sys/types.h>
    #include <sys/stat.h>
    #include <fcntl.h>
    #include <string.h>
    #include <unistd.h>
    int main()
    {
            char buf[30]={0};
            int nff = mkfifo("./demo10.txt",0600);
            if(nff < 0 || errno == EEXIST ){
                    printf("mkfifo error:\n");
                    perror("why");
            }
            if(nff == 0){
                    printf("mkfifo OK! \n");
            }
            int fd = open("./demo10.txt",O_RDONLY);
            printf("open success\n");

            int n_read = read(fd,buf,30);
            printf("read %d byte frome fifo context:\n%s\n",n_read,buf);

            int n_sys = system("rm ./demo10.txt");
            if(n_sys < 0 || n_sys ==127 ){
                    printf("./demo10.txt delect error! \n");
                    perror("why");
            }else{
                    printf("\n--------------------------------------------");
                    printf("\nsystem: ./demo10.txt delect success !\n");
                    printf("--------------------------------------------\n");

            }

            close(fd);
            return 0;
    }

//demo mkwrite:

    #include<stdio.h>
    #include <errno.h>
    #include <sys/types.h>
    #include <sys/stat.h>
    #include <fcntl.h>
    #include <string.h>
    #include <unistd.h>
    int main()
    {
            char buf[30]={"hello mkfifo file_read/write"};

            int fd = open("./demo10.txt",O_WRONLY);
            printf("open success\n");

            int n_write = write(fd,buf,strlen(buf));
            printf("write %d byte frome fifo context:\n%s\n",n_write,buf);

            close(fd);
            return 0;
    }

消息队列

// 生成标准key 给后面msgget用;
// key_t ftok(const char *pathname, int proj_id);

// 获取msgid;
// int msgget(key_t key, int msgflg);

// 添加消息
// int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);

// 读取消息
// ssize_t msgrcv(int msqid, const void *msgp, size_t msgsz,long msgtyp, int msgflg);

// 控制消息队列 比如:杀掉消息队列
// int msgctl(int msqid, int cmd, struct msqid_ds *buf);

//杀掉消息队列 配合实现: msgctl(n_msgget,IPC_RMID,NULL);
// IPC_RMID

//例a:ftok_msgget_msgsnd_msgctl.c

    #include <stdio.h>
    #include <sys/types.h>
    #include <sys/ipc.h>
    #include <sys/msg.h>
    #include <string.h>

    struct NB {
            long msgtyp;
            char data[30];
    };

    int main()
    {
            struct NB ZDNB ={998,"Are you ok?"};
            printf("%ld\n",ZDNB.msgtyp);

            //key_t ftok(const char *pathname, int proj_id);        
            int key = ftok(".",6);

            printf("key = %x\n",key);

            //int msgget(key_t key, int msgflg);
            int n_get =  msgget(key, IPC_CREAT|0777);
            if(n_get >= 0){
                    printf("msgget succes code:%d\n",n_get);
                    perror("why");
            }else{
                    printf("msgget error! code:%d\n",n_get);
                    perror("why");
            }

            //int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
            int snd = msgsnd(n_get,&ZDNB,sizeof(ZDNB.data),0);
            printf("msgsnd code:%d\n",snd);
            perror("why");

            struct NB ZDNB1;
            //ssize_t msgrcv(int msqid, const void *msgp, size_t msgsz,long msgtyp, int msgflg);
            int rcv = msgrcv(n_get,&ZDNB1,sizeof(ZDNB1.data),888,0);
            printf("msgrcv read code:%d\n",rcv);
            printf("--------------------------------------------\n");
            printf("read frome ./rcv_888 massege is:\n%s\n",ZDNB1.data);
            printf("--------------------------------------------\n");

            //int msgctl(int msqid, int cmd, struct msqid_ds *buf);
            int ctl = msgctl(n_get,IPC_RMID,NULL);
            printf("msgctl code:%d\n",ctl);
            perror("why");
            return 0;
    }

//例b:msgrcv.c

    #include<stdio.h>
    #include <sys/types.h>
    #include <sys/ipc.h>
    #include <sys/msg.h>
    #include <string.h>
    #include <unistd.h>
    struct NB {
            long msgtyp;
            char data[30];
    };

    int main()
    {
            struct NB ZNB1 ={888,"I am ok,Thank you!"};
            printf("%ld\n",ZNB1.msgtyp);
            struct NB ZNB;
            //key_t ftok(const char *pathname, int proj_id);        
            int key = ftok(".",6);
            printf("key = %x\n",key);

            //int msgget(key_t key, int msgflg);
            printf("key = %x\n",key);

            //int msgget(key_t key, int msgflg);
            int n_get =  msgget(key, IPC_CREAT|0777);
            if(n_get >= 0){
                    printf("msgget succes code:%d\n",n_get);
                    perror("why");
            }else{
                    printf("msgget error! code:%d\n",n_get);
                    perror("why");
            }

            //ssize_t msgrcv(int msqid, const void *msgp, size_t msgsz,long msgtyp, int msgflg);
            int rcv = msgrcv(n_get,&ZNB,sizeof(ZNB.data),998,0);
            printf("msgrcv read code:%d\n",rcv);
            printf("--------------------------------------------\n");
            printf("read frome ./snd_998 massege is:\n%s\n",ZNB.data);
            printf("--------------------------------------------\n");

            //int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
            int snd = msgsnd(n_get,&ZNB1,sizeof(ZNB1.data),0);
            printf("msgsnd code:%d\n",snd);
            perror("why");

            sleep(1);
            //int msgctl(int msqid, int cmd, struct msqid_ds *buf);
            int ctl = msgctl(n_get,IPC_RMID,NULL);
            printf("msgctl code:%d\n",ctl);
            perror("why");
            return 0;
    }

共享内存_映射

// 生成标准key给shmget用;
// key_t ftok(const char *pathname, int proj_id);

// 生成共享内存ID;
// int shmget(key_t key, size_t size, int shmflg);

// 创建映射;通过共享内存ID; shmaddr 写 0;shmflg 写0;–均代表默认方式;
// void *shmat(int shmid, const void *shmaddr, int shmflg);
// int shmdt(const void *shmaddr); (不常用,因为没返回映射指针)

// 关闭映射;
// int shmdt(const void *shmaddr);

// 使用strcpy();写入映射;
// char *strcpy(char *dest, const char *src);
// char *strncpy(char *dest, const char *src, size_t n);

//printf(“”,);
// 查看当前共享内存映射
// ipcs -m;

// 杀掉共享内存映射ID;
// ipcrm -m shmID;

// 通过内存ID,删除共享文件的内存
// shmctl(shmid,IPC_RMID,0);

//例:shm_strcpy:

    #include <stdio.h>
    #include <sys/types.h>
    #include <sys/ipc.h>
    #include <sys/shm.h>
    #include <unistd.h>
    #include <string.h>
    int main()
    {

            int key = ftok(".",3);
            int shmid = shmget(key,1024*4,IPC_CREAT|0777);
            if(shmid < 0){
                    printf("shmid error ! code:%d\n",shmid);
                    perror("why");
            }
            char *shmaddr = shmat(shmid,0,0);

            char *cpy = strcpy(shmaddr,"hello shm friends!");
            printf("strcpy data to shm:\n%s\n",cpy);
            sleep(5);

            int dt = shmdt(shmaddr);
            if(dt >= 0){
                    printf("shmdt code:%d\n",dt);
                    perror("why");
            }

            shmctl(shmid,IPC_RMID,0);
            printf("quite\n");
            return 0;
    }

//例:shm_printf:

    #include <stdio.h>
    #include <sys/types.h>
    #include <sys/ipc.h>
    #include <sys/shm.h>
    #include <unistd.h>
    #include <string.h>
    int main()
    {

            int key = ftok(".",3);
            int shmid = shmget(key,1024*4,0);
            if(shmid < 0){
                    printf("shmid error ! code:%d\n",shmid);
                    perror("why");
            }
            char *shmaddr = shmat(shmid,0,0);
            printf("from shm data:\n%s\n",shmaddr);
            int dt = shmdt(shmaddr);
            if(dt > 0){
                    printf("shmdt code:%d\n",dt);
                    perror("why");
            }else{
                    perror("why");
            }
            shmctl(shmid,IPC_RMID,0);
            printf("quite\n");
            return 0;
    }

信号编程

查看信号: kill -l

【C语言_文件_进程_进程间通讯 常用函数/命令 + 实例】.md_update:23/10/27,c语言,算法,数据结构

入门级 接收消息 signal signum

//sighandler_t signal(int signum, sighandler_t handler);
DESCRIPTION
signal() sets the disposition of the signal
signum to handler,
The signals SIGKILL and SIGSTOP cannot be caught
or ignored.

//例:

    #include <stdio.h>
    #include <signal.h>
    void handler(int signum)
    {
            printf("signum:%d\n",signum);
            switch(signum){
                    case 2:
                            printf("SIGINT\n");
                            break;
                    case 9:
                            printf("SIGKILL\n");
                            break;
            }
    }
    int main()
    {
            
            signal(SIGINT,handler);
            signal(SIGKILL,handler);
            while(1);
            return 0;
    }
入门级 发送信号 实现杀进程 kill -9 pid

//例:

    #include <stdio.h>
    #include <signal.h>
    #include <stdlib.h>

    int main(int argc,char **argv)
    {
            int num = atoi(argv[1]);
            int pid = atoi(argv[2]);
            char buf[30] = {0};

            sprintf(buf,"kill %d %d",num,pid);
            system(buf);

            return 0;
    }
高级 sigaction 接受信号_携带消息
    #include <stdio.h>
    #include <signal.h>
    #include <sys/types.h>
    #include <unistd.h>

    //void handler(int sig, siginfo_t *info, void *ucontext)
    void handler(int signum, siginfo_t *info, void *ucontext)
    {
            printf("get signum:%d\n",signum);
            if(ucontext != NULL){
                    printf("get data:%d\n",info->si_int);
                    printf("get data:%d\n",info->si_value.sival_int);
                    printf("frome pid:%d\n",info->si_pid);
            }
    }

    int main()
    {
            /*
            struct sigaction {
            void     (*sa_handler)(int);
            void     (*sa_sigaction)(int, siginfo_t *, void *); //if sa_flags = SA_SIGINFO, setthere it is handler;
            sigset_t   sa_mask;
            int        sa_flags; //SA_SIGINFO able get sig;
            void     (*sa_restorer)(void);
            };
            */

            struct sigaction act;

            act.sa_flags = SA_SIGINFO;
            act.sa_sigaction = handler;

            printf("getpid:%d\n",getpid());
            //int sigaction(int signum, const struct sigaction *act, struct sigaction *oldact);

            sigaction(SIGUSR1,&act,NULL);

            while(1);
            return 0;
    }
高级 sigqueue 发送信号_携带消息
    #include <stdio.h>
    #include <signal.h>
    #include <stdlib.h>
    #include <sys/types.h>
    #include <unistd.h>

    int main(int argc,char** argv)
    {

            //moren have 

            /*
            union sigval {
            int   sival_int;
            void *sival_ptr;
            };
            */

            int pid = atoi(argv[2]);
            int signum = atoi(argv[1]);
            union sigval value;
            value.sival_int = 666;

            printf("getpid:%d\n",getpid());
            //int  sigqueue(pid_t  pid, int signum, const union sigval value);
            int que = sigqueue(pid,signum,value);
            if(que >= 0){
                    printf("send int data success!\n");
            }else{
                    perror("why");
            }
            return 0;
    }
信号量编程

信号量(semaphore)与IPC 结构不同,它是一个计数器。信号量用于实现进程间的互斥与同步,而不是用于存储进程间通信数据。

信号量用于进程间同步,若要在进程间传递数据需要结合共享内存。
信号量基于操作系统的 PV 操作,程序对信号量的操作都是原子操作。
每次对信号量的 PV 操作不仅限于对信号量值加 1 或减 1,而且可以加减任意正整数。
支持信号量组。

//例:通过信号量+/-1,实现父子进程,执行顺序控制;

#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <unistd.h>

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
                                (Linux-specific) */
};

// EXAMPLE
// The following code segment uses semop() to atomically wait  for  the
// value  of  semaphore  0 to become zero, and then increment the sema‐
// phore value by one.

//     struct sembuf sops[2];
//     int semid;

//     /* Code to set semid omitted */

//     sops[0].sem_num = 0;        /* Operate on semaphore 0 */
//     sops[0].sem_op = 0;         /* Wait for value to equal 0 */
//     sops[0].sem_flg = 0;

//     sops[1].sem_num = 0;        /* Operate on semaphore 0 */
//     sops[1].sem_op = 1;         /* Increment value by one */
//     sops[1].sem_flg = 0;

//     if (semop(semid, sops, 2) == -1) {
//         perror("semop");
//         exit(EXIT_FAILURE);
//     }

void pGetKey( int semid) //拿锁/信号量
{
    struct sembuf set;
    //int semop(int semid, struct sembuf *sops, size_t nsops);
    set.sem_num = 0;        /* Operate on semaphore 0 */
    set.sem_op = -1;         //对信号量的值-1,拿掉一个锁;
    set.sem_flg = SEM_UNDO;  //在进程终止时自动释放所持有的信号量资源
                                 //释放/公布盒子位置;
    semop(semid, &set, 1);

    printf("get_key sem success!\n");
}

void vPutBackKey( int semid) //还锁/信号量
{
    struct sembuf set;
    //int semop(int semid, struct sembuf *sops, size_t nsops);
    set.sem_num = 0;        /* Operate on semaphore 0 */
    set.sem_op = 1;         //对信号量的值+1,还一个锁;
    set.sem_flg = SEM_UNDO;  //在进程终止时自动释放所持有的信号量资源
                                 //释放/公布盒子位置;
    
    semop(semid, &set, 1);

    printf("back_key sem success!\n\n");
}

int main()
{
    int key = ftok(".",2);
    //int semget(key_t  key,nsems, int semflg);
    //获取/创建 1个信号量/1个盒子;
    int semid = semget (key,1,IPC_CREAT|0666);
    
    union semun initsem;
    initsem.val = 0; //起始信号量的值位0;盒子0个锁;

    //int semctl(int semid, int semnum, int cmd, ...);
    //如果要SETVAL设置信号量的值,需要多加个联合体变量initsem;
    semctl(semid,0,SETVAL,initsem);

    int pid = fork();
    if(pid > 0){
        //去拿锁,但一开始盒子里没有锁,所以就先执行子进程放锁;
        pGetKey(semid); 
        printf("is father pid:%d\n",pid);
        //用完了,再把锁放回盒子;
        vPutBackKey(semid);

        //不需要设值,则3个变量即可,关掉信号量;
        semctl(semid,0,IPC_RMID);
    }else if(pid == 0){
        printf("is child pid:%d\n",pid);
        //子进程放锁进去;
        vPutBackKey(semid);        
    }else{
        printf("fork error! code:%d\n",pid);
        perror("why");
    }

    return 0;
}
信号量+共享内存 实现进程通讯
//例:(双信号量实现)

//双信号量发送端:

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

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
                                    (Linux-specific) */
};

void pGetKey( int semid,int num) //拿锁/信号量
{
        struct sembuf set;
        //int semop(int semid, struct sembuf *sops, size_t nsops);
        set.sem_num = num;        /* Operate on semaphore 0 */
        set.sem_op = -1;         //对信号量的值-1,拿掉一个锁;
        set.sem_flg = SEM_UNDO;  //在进程终止时自动释放所持有的信号量
资源
        //释放/公布盒子位置;
        semop(semid, &set, 1);
        printf("get_key sem success!\n");
}

void vPutBackKey( int semid,int num) //还锁/信号量
{
        struct sembuf set;
        //int semop(int semid, struct sembuf *sops, size_t nsops);
        set.sem_num = num;        /* Operate on semaphore 0 */
        set.sem_op = 1;         //对信号量的值+1,还一个锁;
        set.sem_flg = SEM_UNDO;  //在进程终止时自动释放所持有的信号量
资源
        //释放/公布盒子位置;
        semop(semid, &set, 1);
        printf("back_key sem success!\n\n");
}
int main()
{
        //shmget use key
        int key = ftok(".",3);
        int shmid = shmget(key,1024*4,IPC_CREAT|0777);

        //semget use key2
        int key2 = ftok(".",2);
        //int semget(key_t  key,nsems, int semflg);
        //获取/创建 2个信号量;
        //control控制 rd_wr
        int semid = semget (key2,2,IPC_CREAT|0666);
        //semid是信号集id;

        union semun initsem;
        union semun initsem2;
        initsem.val = 1; //信号量1的值1;1个锁;
        initsem2.val = 0;//信号量2的值0;0个锁;

        //int semctl(int semid, int semnum, int cmd, ...);
        //如果要SETVAL设置信号量的值,需要多加个联合体变量initsem;
        //initsem no.0 
        semctl(semid,0,SETVAL,initsem);
        semctl(semid,1,SETVAL,initsem2);

        pGetKey(semid,0);
        if(shmid < 0){
                printf("shmid error ! code:%d\n",shmid);
                perror("why");
        }
        char *shmaddr = shmat(shmid,0,0);

        char *cpy = strcpy(shmaddr,"hello _sem_shm friends!");
        printf("snd data:\n%s\n",cpy);

        int dt = shmdt(shmaddr);
        if(dt >= 0){
                printf("shmdt code:%d\n",dt);
                perror("why");
        }
        vPutBackKey(semid,1);

        shmctl(shmid,IPC_RMID,0);
        semctl(semid,0,IPC_RMID);
        semctl(semid,1,IPC_RMID);

        printf("quite\n");
        return 0;
}        

//双信号量接收端:

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

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
                                    (Linux-specific) */
};

void pGetKey( int semid,int num) //拿锁/信号量
{
        struct sembuf set;
        //int semop(int semid, struct sembuf *sops, size_t nsops);
        set.sem_num = num;        /* Operate on semaphore 0 */
        set.sem_op = -1;         //对信号量的值-1,拿掉一个锁;
        set.sem_flg = SEM_UNDO;  //在进程终止时自动释放所持有的信号量
资源
        //释放/公布盒子位置;
        semop(semid, &set, 1);
        printf("get_key sem success!\n");
}

void vPutBackKey( int semid,int num) //还锁/信号量
{
        struct sembuf set;
        //int semop(int semid, struct sembuf *sops, size_t nsops);
        set.sem_num = num;        /* Operate on semaphore 0 */
        set.sem_op = 1;         //对信号量的值+1,还一个锁;
        set.sem_flg = SEM_UNDO;  //在进程终止时自动释放所持有的信号量
资源
        //释放/公布盒子位置;
        semop(semid, &set, 1);
        printf("back_key sem success!\n\n");
}
int main()
{
        //shmget use key
        int key = ftok(".",3);
        int shmid = shmget(key,1024*4,IPC_CREAT|0777);

        //semget use key2
        int key2 = ftok(".",2);
        //int semget(key_t  key,nsems, int semflg);
        //获取/创建 2个信号量;
        //control控制 rd_wr
        int semid = semget (key2,2,IPC_CREAT|0666);
        //semid是信号集id;

        union semun initsem;
        union semun initsem2;
        initsem.val = 1; //信号量1的值1;1个锁;
        initsem2.val = 0;//信号量2的值0;0个锁;

        //int semctl(int semid, int semnum, int cmd, ...);
        //如果要SETVAL设置信号量的值,需要多加个联合体变量initsem;
        //initsem no.0 
        semctl(semid,0,SETVAL,initsem);
        semctl(semid,1,SETVAL,initsem2);

        pGetKey(semid,1);
        char *shmaddr = shmat(shmid,0,0);

        printf("from shm data:\n%s\n",shmaddr);

        int dt = shmdt(shmaddr);
        if(dt > 0){
                printf("shmdt code:%d\n",dt);
                perror("why");
        }else{
                perror("why");
        }
        vPutBackKey(semid,0);

        printf("quite\n");
        return 0;
}
//例:(单信号量实现)

//单信号量发送端:

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <sys/shm.h>

#define KEY 1234

// 定义共享内存结构
struct shared_memory {
    int data;
};

// 定义信号量操作结构
struct sembuf sem_op;

int main() {
    int shm_id, sem_id;
    struct shared_memory *shm_ptr;

    // 创建共享内存
    shm_id = shmget(KEY, sizeof(struct shared_memory), IPC_CREAT | 0666);
    if (shm_id == -1) {
        perror("shmget");
        exit(1);
    }

    // 连接共享内存
    shm_ptr = (struct shared_memory *)shmat(shm_id, NULL, 0);
    if (shm_ptr == (struct shared_memory *)(-1)) {
        perror("shmat");
        exit(1);
    }

    // 创建信号量
    sem_id = semget(KEY, 1, IPC_CREAT | 0666);
    if (sem_id == -1) {
        perror("semget");
        exit(1);
    }

    // 初始化信号量
    semctl(sem_id, 0, SETVAL, 1);

    // 写入数据到共享内存
    shm_ptr->data = 42;

    // 通过信号量控制读进程的访问
    sem_op.sem_num = 0;
    sem_op.sem_op = 1;  // 增加信号量值
    sem_op.sem_flg = 0;
    semop(sem_id, &sem_op, 1);

    // 分离共享内存
    shmdt(shm_ptr);

    return 0;
}

//单信号量发送端:文章来源地址https://www.toymoban.com/news/detail-725309.html

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <sys/shm.h>

#define KEY 1234

// 定义共享内存结构
struct shared_memory {
    int data;
};

// 定义信号量操作结构
struct sembuf sem_op;

int main() {
    int shm_id, sem_id;
    struct shared_memory *shm_ptr;

    // 创建共享内存
    shm_id = shmget(KEY, sizeof(struct shared_memory), IPC_CREAT | 0666);
    if (shm_id == -1) {
        perror("shmget");
        exit(1);
    }

    // 连接共享内存
    shm_ptr = (struct shared_memory *)shmat(shm_id, NULL, 0);
    if (shm_ptr == (struct shared_memory *)(-1)) {
        perror("shmat");
        exit(1);
    }

    // 创建信号量
    sem_id = semget(KEY, 1, IPC_CREAT | 0666);
    if (sem_id == -1) {
        perror("semget");
        exit(1);
    }

    // 通过信号量等待写进程完成写入
    sem_op.sem_num = 0;
    sem_op.sem_op = -1;  // 减少信号量值
    sem_op.sem_flg = 0;
    semop(sem_id, &sem_op, 1);

    // 读取共享内存中的数据
    printf("Data read from shared memory: %d\n", shm_ptr->data);

    // 分离共享内存
    shmdt(shm_ptr);

    // 删除共享内存和信号量
    shmctl(shm_id, IPC_RMID, NULL);
    semctl(sem_id, 0, IPC_RMID);

    return 0;
}

更新日志

23/10/27:
	使用markdown编写.md格式,增加目录,
	更新内容:
	a.信号量;
	b.信号量+共享内存实现进程通讯;

到了这里,关于【C语言_文件_进程_进程间通讯 常用函数/命令 + 实例】.md_update:23/10/27的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • MySQL常用函数大全(实例演示)

    此博客主要包括如下类型函数: 一、数字函数 二、字符串函数 三、日期函数 四、MySQL高级函数 1、ABS(x) 返回x的绝对值 结果:  2、AVG(expression) 返回一个表达式的平均值,expression 是一个字段  结果:  3、CEIL(x)/CEILING(x) 返回大于或等于 x 的最小整数 结果:  4、FLOOR(x) 返回小

    2024年02月08日
    浏览(39)
  • 【Linux】常用的文本处理命令详解 + 实例 [⭐实操常用,建议收藏!!⭐]

    👨‍🎓 博主简介   🏅云计算领域优质创作者   🏅华为云开发者社区专家博主   🏅阿里云开发者社区专家博主 💊 交流社区: 运维交流社区 欢迎大家的加入! 🐋 希望大家多多支持,我们一起进步!😄 🎉如果文章对你有帮助的话,欢迎 点赞 👍🏻 评论 💬 收藏

    2024年02月13日
    浏览(44)
  • FFmpeg最常用命令参数详解及应用实例

    FFMPEG堪称自由软件中最完备的一套多媒体支持库,它几乎实现了所有当下常见的数据封装格式、多媒体传输协议以及音视频编解码器,提供了录制、转换以及流化音视频的完整解决方案。 ffmpeg -i [输入文件名] [参数选项] -f [格式] [输出文件] ffmpeg [[ options ][ -i input_file ]]... {[

    2024年01月24日
    浏览(46)
  • 【探索Linux】—— 强大的命令行工具 P.14(进程间通信 | 匿名管道 | |进程池 | pipe() 函数 | mkfifo() 函数)

    当今计算机系统中,进程间通信扮演着至关重要的角色。随着计算机系统的发展和复杂性的增加,多个进程之间的协作变得更加必要和常见。进程间通信使得不同进程能够共享资源、协调工作、传输数据,并实现更加复杂和强大的功能。本文将深入探讨进程间的通信,以及管

    2024年02月05日
    浏览(70)
  • MATLAB科学绘图-MATLAB画图技巧与实例(一):常用函数

    Matlab拥有强大的绘图功能,内置了很多绘图函数,只需要给出一些基本参数就能得到所需图形,这类函数称为 高层绘图函数 。 此外,Matlab还提供了直接对图形句柄进行操作的 低层绘图操作 。这类操作将图形的每个图形元素(如坐标轴、曲线、文字等)看做一个独立的对象

    2024年02月03日
    浏览(45)
  • 【C语言】通讯录(文件) -- 详解

    前面介绍了 【C语言】静态通讯录 -- 详解_炫酷的伊莉娜的博客-CSDN博客 和 【C语言】动态通讯录 -- 详解_炫酷的伊莉娜的博客-CSDN博客 。当通讯录运行起来时,可以对通讯录中的数据进行增加、删除或修改等。此时数据是存放在内存中,当程序退出时,通讯录中的数据自然就

    2024年02月12日
    浏览(36)
  • 【Linux】查看系统各种信息的常用命令 (CPU、内存、进程、网口、磁盘、硬件、等等)

    Linux是一种开源的类Unix操作系统,它有很多不同的发行版,如Ubuntu、CentOS、Debian等。Linux系统提供了很多命令行工具,可以让用户方便地查看和管理系统的各种信息,如硬件配置、内存使用、进程状态、网络连接等。本文将介绍一些常用的命令,以及它们的用法和示例。 使用

    2024年02月15日
    浏览(46)
  • Linux命令200例:ps用于查看当前系统中运行的进程信息(常用)

    🏆作者简介,黑夜开发者,全栈领域新星创作者✌。CSDN专家博主,阿里云社区专家博主,2023年6月csdn上海赛道top4。 🏆数年电商行业从业经验,历任核心研发工程师,项目技术负责人。 🏆本文已收录于专栏:Linux命令大全。 🏆本专栏我们会通过 具体的系统的命令讲解 加上

    2024年02月12日
    浏览(57)
  • C语言实现通讯录(文件版)

    学习完C语言的文件读写,我们又可以将通讯录增加以下功能: 1.当退出通讯录的时候,把已增加的联系人信息写到文件中。 2.当通讯录初始化的时候,加载(读取)文件里的信息到通讯录 ——(直接使用打印函数可以显示在屏幕上) 分析: 当我们退出通讯录的时候要实现通讯录

    2024年02月01日
    浏览(34)
  • 【C语言】实现通讯录(动态+文件)

    在之前三子棋和扫雷的基础上,本篇文章博主将给大家逐步分析实现通讯录,介绍通讯录的每个功能( 动态增长和文件保存 )。 —————————————————————— test.c - 测试通讯录 Contact.c - 函数的实现 Contact.h - 函数和类型的声明 以多文件的形式分模块写的

    2024年02月13日
    浏览(52)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包