Programm mit Semaphoren läuft wunderbar auf Linux...unerwartete Ergebnisse, die auf der Mac osX

Schrieb ich ein einfaches Programm die Lösung des Leser-Schreiber-problem mit Semaphoren. Es läuft perfekt unter Linux os, aber wenn ich es auf meinem Mac osX bekomme ich unerwartete Ergebnisse, und ich kann nicht herausfinden, warum.

Mein Programm:

#include <semaphore.h>
#include <sys/types.h>
#include <stdio.h>
#include <pthread.h>
#include <unistd.h>

void* function1(void* val);
void* function2(void* val);

//shared values
volatile int X;
volatile int Y;

//declare semaphores
sem_t s1;
sem_t s2;

main()
{
void* status;

pthread_t thread1;
pthread_t thread2;
srand(time(NULL));

//initialize semaphores to zero
sem_init(&s1, 0, 0);
sem_init(&s2, 0, 0);

pthread_create(&thread1, NULL, function1, NULL);
pthread_create(&thread2, NULL, function2, NULL);

pthread_join(thread1, &status);
pthread_join(thread2, &status);

sem_destroy(&s1);
sem_destroy(&s2);

}

void* function1(void* val)
{
   while(1)
   {
   X = rand()%1000; //write 
   printf("After thread ID A writes to X, X = %d\n", X);
   sem_post(&s1); //signal
   sem_wait(&s2); //wait
   printf("After thread ID A reads from Y, Y = %d\n", Y); //read
   sleep(3);
   }   
}

void* function2(void* val)
{
   while(1)
   {
    sem_wait(&s1); //wait
    printf("After thread ID B reads from X, X = %d\n", X); //read
    Y = rand()%1000; //write
    printf("After thread ID B write to Y, Y = %d\n", Y);
    sem_post(&s2); //signal
    sleep(3);
   }
}

Die Ausgabe erhalte ich auf Linux (was es Aussehen soll): 

After thread ID A writes to X, X = 100
After thread ID B reads from X, X = 100
After thread ID B write to Y, Y = 234
After thread ID A reads from Y, Y = 234
...

Die Ausgabe auf dem Mac osX (unerwarteten):

After thread ID A writes to X, X = 253
After thread ID A reads from Y, Y = 0
After thread ID B reads from X, X = 253
After thread ID B write to Y, Y = 728
...
  • Keine Lösung, aber jedes mal, wenn ein multi-threaded system funktioniert gut, nur an einer Stelle und haben Sie versucht, die unterschiedlichen überzeugungen von Linux?) aber nicht gut in eine andere Lage, dann würde ich zu Ahnen, eine race-condition.
InformationsquelleAutor Adam Soffer | 2010-11-09
  1. 13

    Überprüfen Sie die Fehler-zurück auf die sem_init Anrufe; ich Wette, Sie finden die OS X-version die Rückgabe einer "Funktion nicht definiert" - Fehler.

    Dies ist, weil Unbenannte POSIX-Semaphoren implementiert nicht auf OS X. Sie müssen die benannte Semaphore oder pthread mutex/condition-Variablen.

    • Dank so viel. Ich war nicht bewusst, dass.
    InformationsquelleAutor David Gelhar
  2. 2

    Nur der Vollständigkeit halber, hier ist eine funktionierende Mac-OS-X-version mit sem_open() und sem_unlink() statt sem_init() und sem_destroy().

    /*
cat semtest.c

source:
"Program using Semaphores runs fine on Linux...unexpected results on Mac osX",
http://stackoverflow.com/questions/4136181/program-using-semaphores-runs-fine-on-linux-unexpected-results-on-mac-osx

compiled on Mac OS X 10.6.8 with:
gcc -ansi -pedantic -std=gnu99 -Os -Wall -Wextra -Wshadow -l pthread -o semtest semtest.c

./semtest

*/


#include <semaphore.h>
#include <sys/types.h>
#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
#include <stdlib.h>

void* function1();
void* function2();

//shared values
volatile int X;
volatile int Y;

//declare semaphores
//sem_t s1;
//sem_t s2;
sem_t *s1;
sem_t *s2;
static const char *semname1 = "Semaphore1";
static const char *semname2 = "Semaphore2";

int main(void)
{

   void* status;

   pthread_t thread1;
   pthread_t thread2;
   srand(time(NULL));

   /*
   //initialize semaphores to zero
   sem_init(&s1, 0, 0);
   sem_init(&s2, 0, 0);
   */

   s1 = sem_open(semname1, O_CREAT, 0777, 0);
   if (s1 == SEM_FAILED)
   {
      fprintf(stderr, "%s\n", "ERROR creating semaphore semname1");
      exit(EXIT_FAILURE);
   }

   s2 = sem_open(semname2, O_CREAT, 0777, 0);
   if (s2 == SEM_FAILED)
   {
      fprintf(stderr, "%s\n", "ERROR creating semaphore semname2");
      exit(EXIT_FAILURE);
   }


   pthread_create(&thread1, NULL, function1, NULL);
   pthread_create(&thread2, NULL, function2, NULL);

   pthread_join(thread1, &status);
   pthread_join(thread2, &status);

   //sem_destroy(&s1);
   //sem_destroy(&s2);
   sem_unlink(semname1);
   sem_unlink(semname2);

   return 0;

}

void* function1()
{
   while(1)
   {
   X = rand()%1000; //write 
   printf("After thread ID A writes to X, X = %d\n", X);
   //sem_post(&s1); //signal
   //sem_wait(&s2); //wait
   sem_post(s1); //signal
   sem_wait(s2); //wait
   printf("After thread ID A reads from Y, Y = %d\n", Y); //read
   sleep(3);
   }   
}

void* function2()
{
   while(1)
   {
    //sem_wait(&s1); //wait
    sem_wait(s1); //wait
    printf("After thread ID B reads from X, X = %d\n", X); //read
    Y = rand()%1000; //write
    printf("After thread ID B write to Y, Y = %d\n", Y);
    //sem_post(&s2); //signal
    sem_post(s2); //signal
    sleep(3);
   }
}
    • Sie haben mein Leben gerettet. Nicht wirklich, aber im Grunde. Ich konnte nichts finden, wie zum initialisieren von Semaphoren auf Mac OS X. ich kann nicht glauben, dass Sie nicht unterstützen Unbenannte Semaphoren...
    InformationsquelleAutor chad
Schreibe einen Kommentar