建站
咨詢
售后
建站咨詢
新聞中心
Linux是一款開源且廣受歡迎的操作系統(tǒng)，由于其優(yōu)異的性能和擴展性，已成為許多企業(yè)和個人使用的首選。Linux中的進程間通信機制讓不同的進程之間能夠互相通信，這對于協(xié)調(diào)程序的執(zhí)行尤其重要。semop是Linux中的信號量操作函數(shù)，它在進程間同步和通信中扮演著重要的角色。
十載的七星網(wǎng)站建設(shè)經(jīng)驗，針對設(shè)計、前端、開發(fā)、售后、文案、推廣等六對一服務(wù)，響應(yīng)快，48小時及時工作處理。營銷型網(wǎng)站的優(yōu)勢是能夠根據(jù)用戶設(shè)備顯示端的尺寸不同，自動調(diào)整七星建站的顯示方式，使網(wǎng)站能夠適用不同顯示終端，在瀏覽器中調(diào)整網(wǎng)站的寬度，無論在任何一種瀏覽器上瀏覽網(wǎng)站，都能展現(xiàn)優(yōu)雅布局與設(shè)計，從而大程度地提升瀏覽體驗。成都創(chuàng)新互聯(lián)從事“七星網(wǎng)站設(shè)計”,“七星網(wǎng)站推廣”以來，每個客戶項目都認真落實執(zhí)行。
信號量是一種整數(shù)類型的變量，并被用于在不同進程之間進行通信和同步。在Linux中，對信號量的操作是由semop實現(xiàn)的，它是System V IPC機制的一部分。System V IPC是一種進程間通信機制，使用IPC通信機制的應(yīng)用程序可以突破單一進程的限制，實現(xiàn)多進程協(xié)作。
semop函數(shù)的主要作用是為不同的進程提供同步機制，它允許一個進程等待其他進程的信號量操作完成。semop的原型如下：
“`
int semop(int semid, struct sembuf *sops, size_t nsops);
“`
semid是含有信號量的標(biāo)識符，sops指向一個結(jié)構(gòu)體sembuf數(shù)組，它描述了需要完成的操作以及對應(yīng)的信號量。nsops指明了sops數(shù)組的大小，它表示了需要對幾個信號量進行處理。sembuf結(jié)構(gòu)體的定義如下：
“`
struct sembuf {
short sem_num; /* 信號量的編號 */
short sem_op; /* 對該信號量執(zhí)行的操作 */
short sem_; /* 操作標(biāo)志 */
};
“`
sem_num代表信號量的編號，從0開始編號。sem_op代表要對該信號量執(zhí)行的操作，可以是正數(shù)、負數(shù)或零。如果sem_op是正數(shù)，表示將信號量的值增加；如果sem_op是負數(shù)，表示將信號量的值減少；如果sem_op是零，表示將等待信號量為零。sem_代表操作標(biāo)志，可以是IPC_NOWT或SEM_UNDO。
IPC_NOWT標(biāo)記表示非阻塞操作，如果當(dāng)前信號量被其它進程占用，將不會阻塞當(dāng)前進程，而是會立即返回。SEM_UNDO標(biāo)記指示在進程異常終止時，內(nèi)核應(yīng)該自動釋放被占用的信號量。
semop有三個參數(shù)，其中semid是調(diào)用semget()函數(shù)創(chuàng)建信號量時返回的標(biāo)識符，sops是一個sembuf類型的結(jié)構(gòu)體指針，指向需要對信號量進行操作的規(guī)范數(shù)組，nsops時sops數(shù)組的大小，也就是需要對幾個信號量進行操作。
當(dāng)使用semop()函數(shù)時，會依次執(zhí)行sops數(shù)組中所有信號量的計數(shù)器及操作，如果出現(xiàn)錯誤則會返回-1。semop()函數(shù)調(diào)用成功返回0，表示操作成功。這時sem_op將被設(shè)置為信號量的當(dāng)前值。
下面是一個簡單的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)建了一個新的信號量，然后通過semctl函數(shù)將信號量的值設(shè)置為1。接下來，程序使用semop函數(shù)將信號量減一，令其變?yōu)?，然后通過semctl函數(shù)獲取信號量的當(dāng)前值。將信號量的值輸出，以驗證semop函數(shù)的正確性。
成都網(wǎng)站建設(shè)公司-創(chuàng)新互聯(lián)為您提供網(wǎng)站建設(shè)、網(wǎng)站制作、網(wǎng)頁設(shè)計及定制高端網(wǎng)站建設(shè)服務(wù)！
linux下c的兩個進程如何實現(xiàn)通信？一個進程給另一個進程發(fā)送消息，另一個接受并顯示出來。求大神啊
linux中的進程通信分為三個部分：低級通信，管道通信和進程間通信IPC（inter process communication）。linux的低級通信主要用來傳遞進程的控制信號——文件鎖和軟中斷信號機制。linux的進程間通信IPC有三個部分——①信號量，②共享內(nèi)存和③消息隊列。以下是我編寫的linux進程通信的C語言實現(xiàn)代碼。操作系統(tǒng)為redhat9.0，編輯器為vi，編譯器采用gcc。下面所有實現(xiàn)代碼均已經(jīng)通過測試，運行無誤。
一.低級通信–信號通信
signal.c
#include 鎮(zhèn)碰
#include
#include 御笑談
/*捕捉到信號sig之后，執(zhí)行預(yù)先預(yù)定的動作函數(shù)*/
void sig_alarm(int sig)
{
printf(“—the signal received is %d. /n”, sig);
signal(SIGINT, SIG_DFL); //SIGINT終端中斷信號，SIG_DFL：恢復(fù)默認行為，SIN_IGN：忽略信號
}
int main()
{
signal(SIGINT, sig_alarm);//捕升賣捉終端中斷信號
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)建管道失敗時，進入循環(huán)
/*進入子進程，子進程向管道中寫入一個字符串*/
if(x==0)
{
sprintf(buf,”This is an example of pipe!/n”);
write(fd,buf,BUFFER_SIZE);
exit(0);
}
/*進入父進程，父進程從管道的另一端讀出剛才寫入的字符串*/
else
{
wait(0);//等待子進程結(jié)束
read(fd,s,BUFFER_SIZE);//讀出字符串，并將其儲存在char s中
printf(“%s”,s);//打印字符串
}
return 0;
}
三.進程間通信——IPC
①信號量通信
sem.c
#include
#include
#include
#include
#include
#include
/*聯(lián)合體變量*/
union semun
{
int val; //信號量初始值
struct semid_ds *buf;
unsigned short int *array;
struct seminfo *__buf;
};
/*函數(shù)聲明，信號量定義*/
static int set_semvalue(void); //設(shè)置信號量
static void del_semvalue(void);//刪除信號量
static int semaphore_p(void); //執(zhí)行P操作
static int semaphore_v(void); //執(zhí)行V操作
static int sem_id;//信號量標(biāo)識符
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)建一個信號量,IPC_CREAT表示創(chuàng)建一個新的信號量
/*如果有參數(shù)，設(shè)置信號量，修改字符*/
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(); //刪除信號量
}
exit(EXIT_SUCCESS);
}
/*設(shè)置信號量*/
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);
}
/*刪除信號量*/
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);
}
②消息隊列通信
send.c
#include
#include
#include
#include
#include
#include
#include
#include
#define MAX_TEXT 512
/*用于消息收發(fā)的結(jié)構(gòu)體–my_msg_type：消息類型，some_text：消息正文*/
struct my_msg_st
{
long int my_msg_type;
char some_text;
};
int main()
{
int running = 1;//程序運行標(biāo)識符
struct my_msg_st some_data;
int msgid;//消息隊列標(biāo)識符
char buffer;
/*創(chuàng)建與接受者相同的消息隊列*/
msgid = msgget((key_t)1234, 0666 | IPC_CREAT);
if (msgid == -1)
{
fprintf(stderr, “msgget failed with error: %d/n”, errno);
exit(EXIT_FAILURE);
}
/*向消息隊列中發(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：消息類型，some_text：消息正文*/
struct my_msg_st
{
long int my_msg_type;
char some_text;
};
int main()
{
int running = 1;//程序運行標(biāo)識符
int msgid; //消息隊列標(biāo)識符
struct my_msg_st some_data;
long int msg_to_receive = 0;//接收消息的類型–0表示msgid隊列上的之一個消息
/*創(chuàng)建消息隊列*/
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;
}
}
/*刪除消息隊列*/
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 //申請共享內(nèi)存大小
struct shared_use_st
{
int written_by_you; //written_by_you為1時表示有數(shù)據(jù)寫入，為0時表示數(shù)據(jù)已經(jīng)被消費者提走
char some_text;
};
producer.c
#include
#include
#include
#include
#include
#include
#include
#include “share.h”
int main()
{
int running = 1; //程序運行標(biāo)志位
void *shared_memory = (void *)0;
struct shared_use_st *shared_stuff;
char buffer;
int shmid; //共享內(nèi)存標(biāo)識符
/*創(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)存連接到一個進程的地址空間中*/
shared_memory = shmat(shmid, (void *)0, 0);//指向共享內(nèi)存之一個字節(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)者寫入數(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ù)用來將共享內(nèi)存從當(dāng)前進程中分離,僅使得當(dāng)前進程不再能使用該共享內(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;//程序運行標(biāo)志位
void *shared_memory = (void *)0;
struct shared_use_st *shared_stuff;
int shmid; //共享內(nèi)存標(biāo)識符
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)存連接到一個進程的地址空間中*/
shared_memory = shmat(shmid, (void *)0, 0);//指向共享內(nèi)存之一個字節(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;
/*消費者讀取數(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ù)用來將共享內(nèi)存從當(dāng)前進程中分離,僅使得當(dāng)前進程不再能使用該共享內(nèi)存*/
if (shmdt(shared_memory) == -1)
{
fprintf(stderr, “shmdt failed/n”);
exit(EXIT_FAILURE);
}
/*將共享內(nèi)存刪除,所有進程均不能再訪問該共享內(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是相對應(yīng)的信號量集中的某一個資源，所以其值是一個從0到相應(yīng)的信號量集的資源總數(shù)殲猛（ipc_perm.sem_nsems）之間的整數(shù)。sem_op指明所要執(zhí)行的操作，sem_說明函數(shù)semop的行為。sem_op的值是一個整數(shù).釋放相應(yīng)的資源數(shù)，將搭改銷sem_op的值加到信號量的值上.
居然一條問題等了四年都沒有人回答
linux進程間通信問題 我想用共享內(nèi)存的方式實現(xiàn)信號量控制一個不許并行的的函數(shù) 請問下面我的代碼合理嗎
看你好像完全搞混了。什么叫用共享內(nèi)存的方式實現(xiàn)信號量控制不能并行的代碼？
首先共享內(nèi)存和信號量都可以實現(xiàn)進程間通信，但是他們的作用或者說使用的方向是有明顯的區(qū)別的：
1：共享內(nèi)存是創(chuàng)建一塊內(nèi)存區(qū)域，多個進程可以同時訪問該區(qū)域，一般用于進程間數(shù)據(jù)傳輸，效率比較明顯基運兄。
2：信號量則完全不同，信號量主要是用來控制臨界資源的訪悄嫌問，也就是你說的不能并行的函數(shù)/代碼。
3：說一下實現(xiàn)，共享內(nèi)存直接用API就可以了，信號量一般會進行封裝，類似于對鏈表的操作進行一些簡單的函數(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就可以使用信號量的p、v操作了，下面給出2個c程序同時操作該信號量的情況，類似于：
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); //獲得信號量，同一時間只有一個進程能獲得該信號量
/* do something */
printf(“count =%d\n”,count++);
sem_v(semid); //釋放信號量
sleep(2);
}
}
int main(void)
{
custom();
}
編譯好，運行的時候先運行server再運行client。
我想你的目的是有一段代碼 （即你標(biāo)的 /*……….只能單獨進行的函數(shù)………*/）
在任意時刻最多只能有最多一個進程執(zhí)行，是吧。
首先，你的臘胡做法是錯的…… 簡單的說，原因是由于
while( *shmaddr );
*shmaddr = 1;
這兩行代碼不是一個原子操作，從while判斷出 *shmaddr等于0 到 *shmaddr=1 之間，另外一個或多個進程可能也會得到 *shmaddr==0 的判斷，從而導(dǎo)致多個進程同時進入 /*……….只能單獨進行的函數(shù)………*/
具體關(guān)于互斥的基本原理，以及你為什么錯，可以找一本講操作系統(tǒng)原理 （關(guān)于進程同步戚局游的高銷內(nèi)容）去看。
所以，用 shared memory 來實現(xiàn)進程同步肯定是不行的，正確的做法是使用 semaphore, 具體可以參考 《unix 環(huán)境高級編程》中關(guān)于 semaphore (信號量）使用的章節(jié)。
關(guān)于linux中semop的介紹到此就結(jié)束了，不知道你從中找到你需要的信息了嗎 ？如果你還想了解更多這方面的信息，記得收藏關(guān)注本站。
創(chuàng)新互聯(lián)-老牌IDC、云計算及IT信息化服務(wù)領(lǐng)域的服務(wù)供應(yīng)商，業(yè)務(wù)涵蓋IDC（互聯(lián)網(wǎng)數(shù)據(jù)中心）服務(wù)、云計算服務(wù)、IT信息化、AI算力租賃平臺（智算云），軟件開發(fā)，網(wǎng)站建設(shè)，咨詢熱線:028-86922220
名稱欄目：Linux中semop：進程間同步和通信的必要操作(linux中semop)
文章網(wǎng)址：http://m.5511xx.com/article/cdjepjd.html
