av激情亚洲男人的天堂国语,日韩欧美精品一中文字幕,无码av一区二区三区无码,国产又色又爽又刺激的a片,国产又色又爽又刺激的a片

Linux中semop:進(jìn)程間同步和通信的必要操作(linux中semop)

Linux是一款開(kāi)源且廣受歡迎的操作系統(tǒng),由于其優(yōu)異的性能和擴(kuò)展性,已成為許多企業(yè)和個(gè)人使用的首選。Linux中的進(jìn)程間通信機(jī)制讓不同的進(jìn)程之間能夠互相通信,這對(duì)于協(xié)調(diào)程序的執(zhí)行尤其重要。semop是Linux中的信號(hào)量操作函數(shù),它在進(jìn)程間同步和通信中扮演著重要的角色。

十載的七星網(wǎng)站建設(shè)經(jīng)驗(yàn),針對(duì)設(shè)計(jì)、前端、開(kāi)發(fā)、售后、文案、推廣等六對(duì)一服務(wù),響應(yīng)快,48小時(shí)及時(shí)工作處理。營(yíng)銷(xiāo)型網(wǎng)站的優(yōu)勢(shì)是能夠根據(jù)用戶設(shè)備顯示端的尺寸不同,自動(dòng)調(diào)整七星建站的顯示方式,使網(wǎng)站能夠適用不同顯示終端,在瀏覽器中調(diào)整網(wǎng)站的寬度,無(wú)論在任何一種瀏覽器上瀏覽網(wǎng)站,都能展現(xiàn)優(yōu)雅布局與設(shè)計(jì),從而大程度地提升瀏覽體驗(yàn)。成都創(chuàng)新互聯(lián)從事“七星網(wǎng)站設(shè)計(jì)”,“七星網(wǎng)站推廣”以來(lái),每個(gè)客戶項(xiàng)目都認(rèn)真落實(shí)執(zhí)行。

信號(hào)量是一種整數(shù)類(lèi)型的變量,并被用于在不同進(jìn)程之間進(jìn)行通信和同步。在Linux中,對(duì)信號(hào)量的操作是由semop實(shí)現(xiàn)的,它是System V IPC機(jī)制的一部分。System V IPC是一種進(jìn)程間通信機(jī)制,使用IPC通信機(jī)制的應(yīng)用程序可以突破單一進(jìn)程的限制,實(shí)現(xiàn)多進(jìn)程協(xié)作。

semop函數(shù)的主要作用是為不同的進(jìn)程提供同步機(jī)制,它允許一個(gè)進(jìn)程等待其他進(jìn)程的信號(hào)量操作完成。semop的原型如下:

“`

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

“`

semid是含有信號(hào)量的標(biāo)識(shí)符,sops指向一個(gè)結(jié)構(gòu)體sembuf數(shù)組,它描述了需要完成的操作以及對(duì)應(yīng)的信號(hào)量。nsops指明了sops數(shù)組的大小,它表示了需要對(duì)幾個(gè)信號(hào)量進(jìn)行處理。sembuf結(jié)構(gòu)體的定義如下:

“`

struct sembuf {

short sem_num; /* 信號(hào)量的編號(hào) */

short sem_op; /* 對(duì)該信號(hào)量執(zhí)行的操作 */

short sem_; /* 操作標(biāo)志 */

};

“`

sem_num代表信號(hào)量的編號(hào),從0開(kāi)始編號(hào)。sem_op代表要對(duì)該信號(hào)量執(zhí)行的操作,可以是正數(shù)、負(fù)數(shù)或零。如果sem_op是正數(shù),表示將信號(hào)量的值增加;如果sem_op是負(fù)數(shù),表示將信號(hào)量的值減少;如果sem_op是零,表示將等待信號(hào)量為零。sem_代表操作標(biāo)志,可以是IPC_NOWT或SEM_UNDO。

IPC_NOWT標(biāo)記表示非阻塞操作,如果當(dāng)前信號(hào)量被其它進(jìn)程占用,將不會(huì)阻塞當(dāng)前進(jìn)程,而是會(huì)立即返回。SEM_UNDO標(biāo)記指示在進(jìn)程異常終止時(shí),內(nèi)核應(yīng)該自動(dòng)釋放被占用的信號(hào)量。

semop有三個(gè)參數(shù),其中semid是調(diào)用semget()函數(shù)創(chuàng)建信號(hào)量時(shí)返回的標(biāo)識(shí)符,sops是一個(gè)sembuf類(lèi)型的結(jié)構(gòu)體指針,指向需要對(duì)信號(hào)量進(jìn)行操作的規(guī)范數(shù)組,nsops時(shí)sops數(shù)組的大小,也就是需要對(duì)幾個(gè)信號(hào)量進(jìn)行操作。

當(dāng)使用semop()函數(shù)時(shí),會(huì)依次執(zhí)行sops數(shù)組中所有信號(hào)量的計(jì)數(shù)器及操作,如果出現(xiàn)錯(cuò)誤則會(huì)返回-1。semop()函數(shù)調(diào)用成功返回0,表示操作成功。這時(shí)sem_op將被設(shè)置為信號(hào)量的當(dāng)前值。

下面是一個(gè)簡(jiǎn)單的semop()函數(shù)應(yīng)用例子:

“`

#include

#include

#include

#include

#include

#include

#include

int mn() {

int semid, val;

struct sembuf semopinfo;

if((semid = semget(IPC_PRIVATE, 1, 0666)) == -1) {

perror(“semget fled.”);

exit(1);

}

if(semctl(semid, 0, SETVAL, 1) == -1) {

perror(“semctl fled.”);

exit(1);

}

semopinfo.sem_num = 0;

semopinfo.sem_op = -1;

semopinfo.sem_ = 0;

if(semop(semid, &semopinfo, 1) == -1) {

perror(“semop fled.”);

exit(1);

}

if(semctl(semid, 0, GETVAL, 1) == -1) {

perror(“semctl fled.”);

exit(1);

}

printf(“The semapho’re value is %d\n”, val);

return 0;

}

“`

上面的例子中,程序使用了semget函數(shù)創(chuàng)建了一個(gè)新的信號(hào)量,然后通過(guò)semctl函數(shù)將信號(hào)量的值設(shè)置為1。接下來(lái),程序使用semop函數(shù)將信號(hào)量減一,令其變?yōu)?,然后通過(guò)semctl函數(shù)獲取信號(hào)量的當(dāng)前值。將信號(hào)量的值輸出,以驗(yàn)證semop函數(shù)的正確性。

成都網(wǎng)站建設(shè)公司-創(chuàng)新互聯(lián)為您提供網(wǎng)站建設(shè)、網(wǎng)站制作、網(wǎng)頁(yè)設(shè)計(jì)及定制高端網(wǎng)站建設(shè)服務(wù)!

linux下c的兩個(gè)進(jìn)程如何實(shí)現(xiàn)通信?一個(gè)進(jìn)程給另一個(gè)進(jìn)程發(fā)送消息,另一個(gè)接受并顯示出來(lái)。求大神啊

linux中的進(jìn)程通信分為三個(gè)部分:低級(jí)通信,管道通信和進(jìn)程間通信IPC(inter process communication)。linux的低級(jí)通信主要用來(lái)傳遞進(jìn)程的控制信號(hào)——文件鎖和軟中斷信號(hào)機(jī)制。linux的進(jìn)程間通信IPC有三個(gè)部分——①信號(hào)量,②共享內(nèi)存和③消息隊(duì)列。以下是我編寫(xiě)的linux進(jìn)程通信的C語(yǔ)言實(shí)現(xiàn)代碼。操作系統(tǒng)為redhat9.0,編輯器為vi,編譯器采用gcc。下面所有實(shí)現(xiàn)代碼均已經(jīng)通過(guò)測(cè)試,運(yùn)行無(wú)誤。

一.低級(jí)通信–信號(hào)通信

signal.c

#include 鎮(zhèn)碰

#include

#include 御笑談

/*捕捉到信號(hào)sig之后,執(zhí)行預(yù)先預(yù)定的動(dòng)作函數(shù)*/

void sig_alarm(int sig)

{

printf(“—the signal received is %d. /n”, sig);

signal(SIGINT, SIG_DFL); //SIGINT終端中斷信號(hào),SIG_DFL:恢復(fù)默認(rèn)行為,SIN_IGN:忽略信號(hào)

}

int main()

{

signal(SIGINT, sig_alarm);//捕升賣(mài)捉終端中斷信號(hào)

while(1)

{

printf(“waiting here!/n”);

sleep(1);

}

return 0;

}

二.管道通信

pipe.c

#include

#define BUFFER_SIZE 30

int main()

{

int x;

int fd;

char buf;

char s;

pipe(fd);//創(chuàng)建管道

while((x=fork())==-1);//創(chuàng)建管道失敗時(shí),進(jìn)入循環(huán)

/*進(jìn)入子進(jìn)程,子進(jìn)程向管道中寫(xiě)入一個(gè)字符串*/

if(x==0)

{

sprintf(buf,”This is an example of pipe!/n”);

write(fd,buf,BUFFER_SIZE);

exit(0);

}

/*進(jìn)入父進(jìn)程,父進(jìn)程從管道的另一端讀出剛才寫(xiě)入的字符串*/

else

{

wait(0);//等待子進(jìn)程結(jié)束

read(fd,s,BUFFER_SIZE);//讀出字符串,并將其儲(chǔ)存在char s中

printf(“%s”,s);//打印字符串

}

return 0;

}

三.進(jìn)程間通信——IPC

①信號(hào)量通信

sem.c

#include

#include

#include

#include

#include

#include

/*聯(lián)合體變量*/

union semun

{

int val; //信號(hào)量初始值

struct semid_ds *buf;

unsigned short int *array;

struct seminfo *__buf;

};

/*函數(shù)聲明,信號(hào)量定義*/

static int set_semvalue(void); //設(shè)置信號(hào)量

static void del_semvalue(void);//刪除信號(hào)量

static int semaphore_p(void); //執(zhí)行P操作

static int semaphore_v(void); //執(zhí)行V操作

static int sem_id;//信號(hào)量標(biāo)識(shí)符

int main(int argc, char *argv)

{

int i;

int pause_time;

char op_char = ‘O’;

srand((unsigned int)getpid());

sem_id = semget((key_t)1234, 1, 0666 | IPC_CREAT);//創(chuàng)建一個(gè)信號(hào)量,IPC_CREAT表示創(chuàng)建一個(gè)新的信號(hào)量

/*如果有參數(shù),設(shè)置信號(hào)量,修改字符*/

if (argc > 1)

{

if (!set_semvalue())

{

fprintf(stderr, “Failed to initialize semaphore/n”);

exit(EXIT_FAILURE);

}

op_char = ‘X’;

sleep(5);

}

for(i = 0; i 1)

{

sleep(10);

del_semvalue(); //刪除信號(hào)量

}

exit(EXIT_SUCCESS);

}

/*設(shè)置信號(hào)量*/

static int set_semvalue(void)

{

union semun sem_union;

sem_union.val = 1;

if (semctl(sem_id, 0, SETVAL, sem_union) == -1)

return(0);

return(1);

}

/*刪除信號(hào)量*/

static void del_semvalue(void)

{

union semun sem_union;

if (semctl(sem_id, 0, IPC_RMID, sem_union) == -1)

fprintf(stderr, “Failed to delete semaphore/n”);

}

/*執(zhí)行P操作*/

static int semaphore_p(void)

{

struct sembuf sem_b;

sem_b.sem_num = 0;

sem_b.sem_op = -1; /* P() */

sem_b.sem_ = SEM_UNDO;

if (semop(sem_id, &sem_b, 1) == -1)

{

fprintf(stderr, “semaphore_p failed/n”);

return(0);

}

return(1);

}

/*執(zhí)行V操作*/

static int semaphore_v(void)

{

struct sembuf sem_b;

sem_b.sem_num = 0;

sem_b.sem_op = 1; /* V() */

sem_b.sem_ = SEM_UNDO;

if (semop(sem_id, &sem_b, 1) == -1)

{

fprintf(stderr, “semaphore_v failed/n”);

return(0);

}

return(1);

}

②消息隊(duì)列通信

send.c

#include

#include

#include

#include

#include

#include

#include

#include

#define MAX_TEXT 512

/*用于消息收發(fā)的結(jié)構(gòu)體–my_msg_type:消息類(lèi)型,some_text:消息正文*/

struct my_msg_st

{

long int my_msg_type;

char some_text;

};

int main()

{

int running = 1;//程序運(yùn)行標(biāo)識(shí)符

struct my_msg_st some_data;

int msgid;//消息隊(duì)列標(biāo)識(shí)符

char buffer;

/*創(chuàng)建與接受者相同的消息隊(duì)列*/

msgid = msgget((key_t)1234, 0666 | IPC_CREAT);

if (msgid == -1)

{

fprintf(stderr, “msgget failed with error: %d/n”, errno);

exit(EXIT_FAILURE);

}

/*向消息隊(duì)列中發(fā)送消息*/

while(running)

{

printf(“Enter some text: “);

fgets(buffer, BUFSIZ, stdin);

some_data.my_msg_type = 1;

strcpy(some_data.some_text, buffer);

if (msgsnd(msgid, (void *)&some_data, MAX_TEXT, 0) == -1)

{

fprintf(stderr, “msgsnd failed/n”);

exit(EXIT_FAILURE);

}

if (strncmp(buffer, “end”, 3) == 0)

{

running = 0;

}

}

exit(EXIT_SUCCESS);

}

receive.c

#include

#include

#include

#include

#include

#include

#include

#include

/*用于消息收發(fā)的結(jié)構(gòu)體–my_msg_type:消息類(lèi)型,some_text:消息正文*/

struct my_msg_st

{

long int my_msg_type;

char some_text;

};

int main()

{

int running = 1;//程序運(yùn)行標(biāo)識(shí)符

int msgid; //消息隊(duì)列標(biāo)識(shí)符

struct my_msg_st some_data;

long int msg_to_receive = 0;//接收消息的類(lèi)型–0表示msgid隊(duì)列上的之一個(gè)消息

/*創(chuàng)建消息隊(duì)列*/

msgid = msgget((key_t)1234, 0666 | IPC_CREAT);

if (msgid == -1)

{

fprintf(stderr, “msgget failed with error: %d/n”, errno);

exit(EXIT_FAILURE);

}

/*接收消息*/

while(running)

{

if (msgrcv(msgid, (void *)&some_data, BUFSIZ,msg_to_receive, 0) == -1)

{

fprintf(stderr, “msgrcv failed with error: %d/n”, errno);

exit(EXIT_FAILURE);

}

printf(“You wrote: %s”, some_data.some_text);

if (strncmp(some_data.some_text, “end”, 3) == 0)

{

running = 0;

}

}

/*刪除消息隊(duì)列*/

if (msgctl(msgid, IPC_RMID, 0) == -1)

{

fprintf(stderr, “msgctl(IPC_RMID) failed/n”);

exit(EXIT_FAILURE);

}

exit(EXIT_SUCCESS);

}

③共享內(nèi)存通信

share.h

#define TEXT_SZ 2023 //申請(qǐng)共享內(nèi)存大小

struct shared_use_st

{

int written_by_you; //written_by_you為1時(shí)表示有數(shù)據(jù)寫(xiě)入,為0時(shí)表示數(shù)據(jù)已經(jīng)被消費(fèi)者提走

char some_text;

};

producer.c

#include

#include

#include

#include

#include

#include

#include

#include “share.h”

int main()

{

int running = 1; //程序運(yùn)行標(biāo)志位

void *shared_memory = (void *)0;

struct shared_use_st *shared_stuff;

char buffer;

int shmid; //共享內(nèi)存標(biāo)識(shí)符

/*創(chuàng)建共享內(nèi)存*/

shmid = shmget((key_t)1234, sizeof(struct shared_use_st), 0666 | IPC_CREAT);

if (shmid == -1)

{

fprintf(stderr, “shmget failed/n”);

exit(EXIT_FAILURE);

}

/*將共享內(nèi)存連接到一個(gè)進(jìn)程的地址空間中*/

shared_memory = shmat(shmid, (void *)0, 0);//指向共享內(nèi)存之一個(gè)字節(jié)的指針

if (shared_memory == (void *)-1)

{

fprintf(stderr, “shmat failed/n”);

exit(EXIT_FAILURE);

}

printf(“Memory attached at %X/n”, (int)shared_memory);

shared_stuff = (struct shared_use_st *)shared_memory;

/*生產(chǎn)者寫(xiě)入數(shù)據(jù)*/

while(running)

{

while(shared_stuff->written_by_you == 1)

{

sleep(1);

printf(“waiting for client…/n”);

}

printf(“Enter some text: “);

fgets(buffer, BUFSIZ, stdin);

strncpy(shared_stuff->some_text, buffer, TEXT_SZ);

shared_stuff->written_by_you = 1;

if (strncmp(buffer, “end”, 3) == 0)

{

running = 0;

}

}

/*該函數(shù)用來(lái)將共享內(nèi)存從當(dāng)前進(jìn)程中分離,僅使得當(dāng)前進(jìn)程不再能使用該共享內(nèi)存*/

if (shmdt(shared_memory) == -1)

{

fprintf(stderr, “shmdt failed/n”);

exit(EXIT_FAILURE);

}

printf(“producer exit./n”);

exit(EXIT_SUCCESS);

}

customer.c

#include

#include

#include

#include

#include

#include

#include

#include “share.h”

int main()

{

int running = 1;//程序運(yùn)行標(biāo)志位

void *shared_memory = (void *)0;

struct shared_use_st *shared_stuff;

int shmid; //共享內(nèi)存標(biāo)識(shí)符

srand((unsigned int)getpid());

/*創(chuàng)建共享內(nèi)存*/

shmid = shmget((key_t)1234, sizeof(struct shared_use_st), 0666 | IPC_CREAT);

if (shmid == -1)

{

fprintf(stderr, “shmget failed/n”);

exit(EXIT_FAILURE);

}

/*將共享內(nèi)存連接到一個(gè)進(jìn)程的地址空間中*/

shared_memory = shmat(shmid, (void *)0, 0);//指向共享內(nèi)存之一個(gè)字節(jié)的指針

if (shared_memory == (void *)-1)

{

fprintf(stderr, “shmat failed/n”);

exit(EXIT_FAILURE);

}

printf(“Memory attached at %X/n”, (int)shared_memory);

shared_stuff = (struct shared_use_st *)shared_memory;

shared_stuff->written_by_you = 0;

/*消費(fèi)者讀取數(shù)據(jù)*/

while(running)

{

if (shared_stuff->written_by_you)

{

printf(“You wrote: %s”, shared_stuff->some_text);

sleep( rand() % 4 );

shared_stuff->written_by_you = 0;

if (strncmp(shared_stuff->some_text, “end”, 3) == 0)

{

running = 0;

}

}

}

/*該函數(shù)用來(lái)將共享內(nèi)存從當(dāng)前進(jìn)程中分離,僅使得當(dāng)前進(jìn)程不再能使用該共享內(nèi)存*/

if (shmdt(shared_memory) == -1)

{

fprintf(stderr, “shmdt failed/n”);

exit(EXIT_FAILURE);

}

/*將共享內(nèi)存刪除,所有進(jìn)程均不能再訪問(wèn)該共享內(nèi)存*/

if (shmctl(shmid, IPC_RMID, 0) == -1)

{

fprintf(stderr, “shmctl(IPC_RMID) failed/n”);

exit(EXIT_FAILURE);

}

exit(EXIT_SUCCESS);

}

摘自:

linux 下的 struct sembuf 是什么數(shù)據(jù)結(jié)構(gòu)阿

struct sembuf

{

unsigned short int sem_num; /咐返橡世吵* semaphore number */

short int sem_op; /* semaphore operation */

short int sem_; /* operation flag */衡旁

};

在sembuf結(jié)構(gòu)知游中,sem_num是相對(duì)應(yīng)的信號(hào)量集中的某一個(gè)資源,所以其值是一個(gè)從0到相應(yīng)的信號(hào)量集的資源總數(shù)殲猛(ipc_perm.sem_nsems)之間的整數(shù)。sem_op指明所要執(zhí)行的操作,sem_說(shuō)明函數(shù)semop的行為。sem_op的值是一個(gè)整數(shù).釋放相應(yīng)的資源數(shù),將搭改銷(xiāo)sem_op的值加到信號(hào)量的值上.

居然一條問(wèn)題等了四年都沒(méi)有人回答

linux進(jìn)程間通信問(wèn)題 我想用共享內(nèi)存的方式實(shí)現(xiàn)信號(hào)量控制一個(gè)不許并行的的函數(shù) 請(qǐng)問(wèn)下面我的代碼合理嗎

看你好像完全搞混了。什么叫用共享內(nèi)存的方式實(shí)現(xiàn)信號(hào)量控制不能并行的代碼?

首先共享內(nèi)存和信號(hào)量都可以實(shí)現(xiàn)進(jìn)程間通信,但是他們的作用或者說(shuō)使用的方向是有明顯的區(qū)別的:

1:共享內(nèi)存是創(chuàng)建一塊內(nèi)存區(qū)域,多個(gè)進(jìn)程可以同時(shí)訪問(wèn)該區(qū)域,一般用于進(jìn)程間數(shù)據(jù)傳輸,效率比較明顯基運(yùn)兄。

2:信號(hào)量則完全不同,信號(hào)量主要是用來(lái)控制臨界資源的訪悄嫌問(wèn),也就是你說(shuō)的不能并行的函數(shù)/代碼。

3:說(shuō)一下實(shí)現(xiàn),共享內(nèi)存直接用API就可以了,信號(hào)量一般會(huì)進(jìn)行封裝,類(lèi)似于對(duì)鏈表的操作進(jìn)行一些簡(jiǎn)單的函數(shù)封裝一樣,下面給出信號(hào)量的使用實(shí)例代碼,可以參考:

sem_ctl.c文件內(nèi)容:

int init_sem(int sem_id,int init_value)

{

union semun sem_union;

sem_union.val = init_value;

if(semctl(sem_id,0,SETVAL,sem_union) == -1)

{

perror(“semctl”);

return -1;

}

return 0;

}

int del_sem(int sem_id)

{

union semun sem_union;

if(semctl(sem_id,0,IPC_RMID,sem_union) == -1)

{

perror(“delete semaphore”);

return -1;

}

return 0;

}

int sem_p(int sem_id)

{

struct sembuf sem_b;

sem_b.sem_num = 0;

sem_b.sem_op = -1;

sem_b.sem_ = SEM_UNDO;

if(semop(sem_id,&sem_b,1) ==-1)

{

perror(“P operation”);

return -1;

}

return 0;

}

int sem_v(int sem_id)

{

struct sembuf sem_b;

sem_b.sem_num = 0;

sem_b.sem_op = 1;

sem_b.sem_ = SEM_UNDO;

if(semop(sem_id,&sem_b,1) == -1)

{

perror(“V opration”);

return -1;

}

return 0;

}

sem_ctl.h文件內(nèi)容搏襲:

#include

#include

#include

#include

#include

#include

#include

#define MAX 128

int count; //全局變量,即臨界資源

union semun{

int val;

struct semid_ds *buf;

unsigned short *array;

struct seminfo *__buf;

};

int init_sem(int sem_id,int init_value);

int del_sem(int sem_id);

int sem_p(int sem_id);

int sem_v(int sem_id);

在應(yīng)用程序中只要包含sem_ctl.h就可以使用信號(hào)量的p、v操作了,下面給出2個(gè)c程序同時(shí)操作該信號(hào)量的情況,類(lèi)似于:

server.c文件內(nèi)容如下:

#include “util.h”

#include

int semid;

void sighandler(int signo)

{

del_sem(semid);

exit(0);

}

void server()

{

key_t key;

initcount();

if((key = ftok(“.”,’e’)) == -1)

{

perror(“ftok”);

exit(1);

}

if((semid = semget(key,1,0666|IPC_CREAT|IPC_EXCL)) == -1)

{

perror(“semget”);

exit(1);

}

printf(“the semid is :%d\n”,semid);

init_sem(semid, 0);

signal(SIGINT,sighandler);

signal(SIGUSR1,sighandler);

signal(SIGALRM,sighandler);

while(1)

{

sem_p(semid);

/* do something */

printf(“count =%d\n”,count++);

sem_v(semid);

sleep(2);

}

}

int main(void)

{

server();

}

client.c文件內(nèi)容如下:

#include “sem_ctl.h”

void custom()

{

int semid;

key_t key;

if((key = ftok(“.”,’e’)) == -1)

{

perror(“ftok”);

exit(1);

}

if((semid = semget(key,0,0)) == -1)

{

perror(“semget”);

exit(1);

}

printf(“the semid is :%d\n”,semid);

while(1)

{

sem_p(semid); //獲得信號(hào)量,同一時(shí)間只有一個(gè)進(jìn)程能獲得該信號(hào)量

/* do something */

printf(“count =%d\n”,count++);

sem_v(semid); //釋放信號(hào)量

sleep(2);

}

}

int main(void)

{

custom();

}

編譯好,運(yùn)行的時(shí)候先運(yùn)行server再運(yùn)行client。

我想你的目的是有一段代碼 (即你標(biāo)的 /*……….只能單獨(dú)進(jìn)行的函數(shù)………*/)

在任意時(shí)刻最多只能有最多一個(gè)進(jìn)程執(zhí)行,是吧。

首先,你的臘胡做法是錯(cuò)的…… 簡(jiǎn)單的說(shuō),原因是由于

while( *shmaddr );

*shmaddr = 1;

這兩行代碼不是一個(gè)原子操作,從while判斷出 *shmaddr等于0 到 *shmaddr=1 之間,另外一個(gè)或多個(gè)進(jìn)程可能也會(huì)得到 *shmaddr==0 的判斷,從而導(dǎo)致多個(gè)進(jìn)程同時(shí)進(jìn)入 /*……….只能單獨(dú)進(jìn)行的函數(shù)………*/

具體關(guān)于互斥的基本原理,以及你為什么錯(cuò),可以找一本講操作系統(tǒng)原理 (關(guān)于進(jìn)程同步戚局游的高銷(xiāo)內(nèi)容)去看。

所以,用 shared memory 來(lái)實(shí)現(xiàn)進(jìn)程同步肯定是不行的,正確的做法是使用 semaphore, 具體可以參考 《unix 環(huán)境高級(jí)編程》中關(guān)于 semaphore (信號(hào)量)使用的章節(jié)。

關(guān)于linux中semop的介紹到此就結(jié)束了,不知道你從中找到你需要的信息了嗎 ?如果你還想了解更多這方面的信息,記得收藏關(guān)注本站。

創(chuàng)新互聯(lián)-老牌IDC、云計(jì)算及IT信息化服務(wù)領(lǐng)域的服務(wù)供應(yīng)商,業(yè)務(wù)涵蓋IDC(互聯(lián)網(wǎng)數(shù)據(jù)中心)服務(wù)、云計(jì)算服務(wù)、IT信息化、AI算力租賃平臺(tái)(智算云),軟件開(kāi)發(fā),網(wǎng)站建設(shè),咨詢熱線:028-86922220


當(dāng)前標(biāo)題:Linux中semop:進(jìn)程間同步和通信的必要操作(linux中semop)
瀏覽路徑:http://uogjgqi.cn/article/cdjepjd.html
掃二維碼與項(xiàng)目經(jīng)理溝通

我們?cè)谖⑿派?4小時(shí)期待你的聲音

解答本文疑問(wèn)/技術(shù)咨詢/運(yùn)營(yíng)咨詢/技術(shù)建議/互聯(lián)網(wǎng)交流