與信號量共享內存同步

Question

爲了做作業，我需要使用IPC。我爲共享內存編寫了一些代碼，但它不能按我的需要工作。我希望服務器進程在客戶端之前運行。我做錯了什麼？如何解決它？

//main.cpp 
#include "stockexchangeserver.h" 
#include "stockexchangeclient.h" 
#include <semaphore.h> 

int main(int argc,char *argv[]) 
{ 
    StockExchangeServer server; 
    StockExchangeClient client; 
    pid_t pid; 
    sem_t sem; 
    int pshared = 1; 
    unsigned int value = 0; 
    sem_init(&sem,pshared,value); 

    if ((pid = fork()) < 0) { 
     std::cout<<"fork error\n"; 
    } else if (pid > 0) { 
     sem_wait(&sem); 
     client.start2(); 
     sem_post(&sem); 
    } else { 
     server.start2(); 
     sem_post(&sem); 
    } 
    return 0; 
} 

    //stockexchangeclient.cpp 
    void StockExchangeClient::start2() { 
    int sharedMemoryId; 
    key_t key; 
    int *shm; 
    key = 6000; 

    if((sharedMemoryId = shmget(key,sizeof(int),0666)) < 0) { 
     std::cout<<"Shared memory create error\n"; 
     exit(1); 
    } 
    else{} 

    if((shm = (int *)shmat(sharedMemoryId,NULL,0)) == (int *)-1) { 
     std::cout<<"Shared memory attach error\n"; 
     exit(1); 
    } 
    else{} 
    *shm = 1; 
    exit(0); 
} 

//stockexchangeserver.cpp 
void StockExchangeServer::start2() 
{ 
    int sharedMemoryId; 
    key_t key; 
    int *shm; 
    key = 6000; 

    if((sharedMemoryId = shmget(key,sizeof(int),IPC_CREAT | 0666)) < 0) { 
     std::cout<<"Shared memory create error\n"; 
     exit(1); 
    } 
    else{} 
    if((shm = (int *)shmat(sharedMemoryId,NULL,0)) == (int *)-1) { 
     std::cout<<"Shared memory attach error\n"; 
     exit(1); 
    } 
    else{} 
    *shm = 0; 
    while(*shm == 0) { 
     sleep(1); 
    } 
    std::cout<<"Shared memory succeded\n"; 
} 

Answer 1

我測試了這一點，其實服務器進程第一（StockExchangeServer::start2）運行，但問題是在

while(*shm == 0) { 
    sleep(1); 
} 

這導致一個無限循環，你是不是給一個機會StockExchangeClient::start2()更改*shm作爲父母等待無限期在sem_wait作爲孩子從未執行sem_post

而不是可以做一個sem_post在進入循環之前，以便您從sem_wait中釋放父項。爲此，您需要發送&sem至StockExchangeServer::start2。可能是將其原型改爲StockExchangeServer::start2(sem_t *sem)之類的東西。

但作爲sem是未命名信號，和2份存在，一個在父母和一個兒童，如果你想同時父母和孩子使用它，你需要使用一個共享內存區域來創建它shmget，然後跨進程訪問它。如果你不想所有這些痛苦，你可以切換到命名信號量甚至可以通過不相關的進程訪問。 簡而言之，未命名的信號通常用於線程（作爲線程共享數據）併爲進程命名信號量。

此外，由David Schwartz在評論中指出，確保防止while循環的無意優化。舉例來說，在循環之前打印出shm的值。