Diseñar una cola para que sea una memoria compartida

Question

Estoy intentando diseñar/implementar una cola (circular) (en C) como una memoria compartida para que pueda compartirse entre múltiples hilos/procesos.

La estructura de colas es como sigue:

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

que soporta las siguientes funciones:

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); 

Según el tamaño de la cola por parte del usuario, la memoria para q_data se asignarán en create_q().

Pregunta: ¿Cómo crear una memoria compartida para esta cola usando las funciones del sistema proporcionadas en "sys/shm.h"? Cualquier fragmento de código/ejemplo para crear/adjuntar/recuperar/eliminar memoria compartida para la estructura de datos de la cola usando shmget(), shmat(), shmctl(), etc. sería de gran ayuda.

Answer 1

Cuando ensuciado con Unix IPC, he seguido Beej's guide to Unix IPC. ¡Incluso tiene algunas bromas! Puede ir directamente al shared memory section. Tiene fragmentos que explican cada paso y un ejemplo completo al final.

Answer 2

Aquí hay un ejemplo simple que crea memoria compartida del tamaño de una estructura, escribe algunos datos y la imprime. Ejecute una instancia y creará la memoria compartida y pondrá algunos "datos" en ella, y luego esperará a que se presione una tecla. Ejecute una segunda instancia en un símbolo del sistema diferente, y la segunda instancia imprimirá el contenido de la memoria.

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; 
}