Thiết kế một Hàng đợi là bộ nhớ dùng chung

Question

Tôi đang cố gắng thiết kế/triển khai hàng đợi (tròn) (trong C) làm bộ nhớ dùng chung để có thể chia sẻ giữa nhiều luồng/quy trình.

Cấu trúc hàng đợi là như sau:

typedef struct _q { 
    int q_size; 
    int q_front; 
    int q_rear; 
    int *q_data; 
}queue; 

nào hỗ trợ các chức năng sau:

int empty_q(queue *q); 
int display_q(queue *q); 
int create_q(queue **q, int size); 
int delete_q(queue **q); 
int enqueue(queue *q, int data); 
int dequeue(queue *q, int *data); 

Theo kích thước hàng đợi được đề cập bởi người dùng, bộ nhớ cho q_data sẽ được phân bổ trong create_q().

Câu hỏi: Cách tạo bộ nhớ dùng chung cho hàng đợi này bằng cách sử dụng các chức năng hệ thống được cung cấp trong "sys/shm.h"? Bất kỳ đoạn mã/ví dụ nào để tạo/đính kèm/truy xuất/xóa bộ nhớ chia sẻ cho cấu trúc dữ liệu hàng đợi bằng cách sử dụng shmget(), shmat(), shmctl(), vv sẽ là một trợ giúp tuyệt vời.

Answer 1

Khi tôi nhầm lẫn với Unix IPC, tôi theo dõi Beej's guide to Unix IPC. Nó thậm chí còn có một số câu chuyện cười! Bạn có thể truy cập trực tiếp vào shared memory section. Nó có đoạn giải thích từng bước, và một ví dụ đầy đủ ở cuối.

Answer 2

Đây là một ví dụ đơn giản tạo bộ nhớ chia sẻ với kích thước của cấu trúc, viết một số dữ liệu vào nó và in ra. Chạy một thể hiện và nó sẽ tạo ra bộ nhớ chia sẻ và đặt một số "dữ liệu" vào nó, và sau đó chờ đợi một phím bấm. Chạy một thể hiện thứ hai trong một dấu nhắc lệnh khác, và cá thể thứ hai sẽ in nội dung của bộ nhớ.

typedef struct 
    { 
    char a[24]; 
    int i; 
    int j; 
    } somestruct; 


void fillshm(int shmid) { 
    somestruct *p; 

    if ((p = shmat (shmid, NULL, 0)) < 0) 
     { 
     perror("shmat"); 
     exit(1); 
     } 

    printf("writing to shared memory\n"); 
    strcpy(p->a, "my shared memory"); 
    p->i = 123; 
    p->j = 456; 
} 


void printshm(int shmid) 
{ 
    somestruct *p; 
    if ((p = shmat (shmid, NULL, 0)) < 0) 
     { 
     perror("shmat"); 
     exit(1); 
     } 

    printf("%s, %d, %d\n", p->a, p->i, p->j); 
} 

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

    int shmid; 

    // see if the memory exists and print it if so 
    if ((shmid = shmget (1234, 0, 0)) >= 0) 
     printshm(shmid); 
    else 
     { 
     // didn't exist, so create it 
     if ((shmid = shmget (1234, sizeof(somestruct), IPC_CREAT | 0600)) < 0) 
     { 
     perror("shmget"); 
     exit(1); 
     } 

     printf("shmid = %d\n", shmid); 

     fillshm(shmid); 
     printf("Run another instance of this app to read the memory... (press a key): "); 
     getchar(); 

     // delete it 
     if (shmctl (shmid, IPC_RMID, NULL) < 0) 
     { 
     perror("semctl"); 
     exit(1); 
     } 
     } 

    return 0; 
}