Witam wszystkich, otóż próboję rozgryźć, dlaczego program blokuje się po pewnym czasie działania. Wątki nie kończą działania, więc powinny wykonywać się non stop. Blokade można zaobserwowąć po tym kiedy to wątek dojedzie do miasta, posiedzi w nim trochę i ustawia się w kolejce, w tym miejscu następuje blokada dla pewngo wątku, kilka poprzednich o dziwo działa bezproblemowo(?).
Polecenie:
Z miasta A do miasta B prowadzi droga, na której znajduje się wąski most umożliwiający tylko ruch jednokierunkowy.
- Most jest również dość słaby, także może po nim przejeżdżać tylko jeden samochód na raz.
- Napisać program w którym N samochodów (wątków) będzie nieustannie przejeżdżało z miasta do miasta, pokonując po drodze most (N przekazywane jako argument linii poleceń).
- Zsynchronizuj dostęp wątków do mostu:
a. nie wykorzystując zmiennych warunkowych (tylko mutexy/semafory)
b .wykorzystując zmienne warunkowe (condition variables)
Aby móc obserwować działanie programu, każdemu samochodowi przydziel numer. Program powinien wypisywać komunikaty według poniższego przykładu:
A-5 10>>> [>> 4 >>] <<<4 6-B
Oznacza to, że po stronie miasta A jest 15 samochodów
- z czego 10 czeka w kolejce przed mostem,
- przez most przejeżdża samochód z numerem 4 z miasta A do B,
- po stronie miasta B jest 10 samochodów, z czego 4 oczekują w kolejce przed mostem.
- Po uruchomieniu programu z parametrem -debug należy wypisywać całą zawartość kolejek po obu stronach mostu, nie tylko ilość samochodów.
- Komunikat należy wypisywać w momencie, kiedy w programie zmieni się którakolwiek z tych wartości.
Uruchomienie programu: ./program -liczbaWatku
#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <errno.h>
#include <string.h>
pthread_mutex_t most; // Zabezpiecza przejazd przez most tylko przez 1 samochod
pthread_mutex_t miasto; // Zabezpiecza zmienna wMiescieA
pthread_mutex_t miasto; // Zabezpiecza zmienna wMiescieB
pthread_mutex_t scrLock;
pthread_cond_t warKolejki = PTHREAD_COND_INITIALIZER;
int wKolejceA; // 0 - miasto A, 1 - miasto B
int wKolejceB;
int wMiescie[2]; // 0 - miasto A, 1 - miasto B
int *kolejkaA;
int *kolejkaB;
int ilWatkow = 0; // Zmienna zliczajaca ile watkow sie utworzylo
int lSamochodow = 0; // Zmienna przechowujaca liczbe samochodow z parametru
int trybDebug = 0; // 0 - brak, 1 - tryb debug
void wypiszKolejke(int miasto) {
int i;
if (miasto == 0) {
printf("____Kolejka miasta A: ");
for (i = 0; i < lSamochodow; i++)
printf("%d ", kolejkaA[i]);
} else if (miasto == 1) {
printf("____Kolejka miasta B: ");
for (i = 0; i < lSamochodow; i++)
printf("%d ", kolejkaB[i]);
}
}
int pierwszyWKolejce(int numerWatku, int miasto) {
if (miasto == 0) {
if (kolejkaA[0] == numerWatku) return 1;
else return 0;
} else {
if (kolejkaB[0] == numerWatku) return 1;
else return 0;
}
}
int usunZKolejki(int numerWatku, int miasto) {
int i = 0;
if (miasto == 0) // A
{
if (kolejkaA[0] == numerWatku) {
//Szukanie pierwszego wolnego indeksu, czyli kolejkaA[ind] = 0
int indZero = 0;
while (kolejkaA[indZero] != 0)
indZero++;
indZero--;
while (i < lSamochodow - 1) {
kolejkaA[i] = kolejkaA[i + 1];
i++;
}
while (indZero < lSamochodow) {
kolejkaA[indZero] = 0;
indZero++;
}
printf("\nUsunieto samochod nr %d z kolejki miasta A", numerWatku);
wypiszKolejke(miasto);
return 1;
} else {
printf("\nSamochod ktory chesz usunac nie jest pierwszy!");
return 0;
}
} else {
if (kolejkaB[0] == numerWatku) {
//Szukanie pierwszego wolnego indeksu, czyli kolejkaB[ind] = 0
int indZero = 0;
while (kolejkaB[indZero] != 0)
indZero++;
indZero--;
while (i < lSamochodow - 1) {
kolejkaB[i] = kolejkaB[i + 1];
i++;
}
while (indZero < lSamochodow) {
kolejkaB[indZero] = 0;
indZero++;
}
printf("\nUsunieto samochod nr %d z kolejki miasta B", numerWatku);
wypiszKolejke(miasto);
return 1;
} else {
printf("\nSamochod ktory chesz usunac nie jest pierwszy!");
return 0;
}
}
}
int dodajDoKolejki(int numerWatku, int miasto, int inicjuj) {
if (miasto == 0) // A
{
int i = 0;
while (kolejkaA[i] != 0) i++;
kolejkaA[i] = numerWatku;
if (inicjuj == 1)
pthread_mutex_lock(&scrLock);
printf("\nDodalo watek %d do kolejki miasta A", numerWatku);
wypiszKolejke(miasto);
if (inicjuj == 1)
pthread_mutex_unlock(&scrLock);
return 1;
} else if (miasto == 1) {
int i = 0;
while (kolejkaB[i] != 0) i++;
kolejkaB[i] = numerWatku;
if (inicjuj == 1)
pthread_mutex_lock(&scrLock);
printf("\nDodalo watek %d do kolejki miasta B", numerWatku);
wypiszKolejke(miasto);
if (inicjuj == 1)
pthread_mutex_unlock(&scrLock);
return 1;
} else {
printf("\nBLAD DODAWANIA DO KOLEJKI");
return 0; // Blad
}
}
void jedzNaMiasto(int numerWatku, int miasto) {
if (miasto == 0) {
pthread_mutex_lock(&miasto);
pthread_mutex_lock(&scrLock);
wMiescie[0]++;
printf("\nA-%d %d>>> [ BLANK ] <<<%d %d-B", wMiescie[0], wKolejceA, wKolejceB, wMiescie[1]);
wMiescie[0]--;
printf("\nA-%d %d>>> [ BLANK ] <<<%d %d-B", wMiescie[0], wKolejceA, wKolejceB, wMiescie[1]);
wKolejceA++;
dodajDoKolejki(numerWatku, miasto, 0);
pthread_mutex_unlock(&miasto);
printf("\nA-%d %d>>> [ BLANK ] <<<%d %d-B", wMiescie[0], wKolejceA, wKolejceB, wMiescie[1]);
pthread_cond_broadcast(&warKolejki);
pthread_mutex_unlock(&scrLock);
sleep(1);
aDoB(numerWatku, miasto);
} else {
pthread_mutex_lock(&miasto);
pthread_mutex_lock(&scrLock);
wMiescie[1]++;
printf("\nA-%d %d>>> [ BLANK ] <<<%d %d-B", wMiescie[0], wKolejceA, wKolejceB, wMiescie[1]);
wMiescie[1]--;
printf("\nA-%d %d>>> [ BLANK ] <<<%d %d-B", wMiescie[0], wKolejceA, wKolejceB, wMiescie[1]);
wKolejceB++;
dodajDoKolejki(numerWatku, miasto, 0);
pthread_mutex_unlock(&miasto);
printf("\nA-%d %d>>> [ BLANK ] <<<%d %d-B", wMiescie[0], wKolejceA, wKolejceB, wMiescie[1]);
pthread_cond_broadcast(&warKolejki);
pthread_mutex_unlock(&scrLock);
sleep(1);
bDoA(numerWatku, miasto);
}
}
void aDoB(int numerWatku, int miasto) {
pthread_mutex_lock(&most);
do {
if (pierwszyWKolejce(numerWatku, miasto) == 1) {
pthread_mutex_lock(&miasto);
pthread_mutex_lock(&scrLock);
wKolejceA--;
usunZKolejki(numerWatku, miasto);
pthread_mutex_unlock(&miasto);
printf("\nA-%d %d>>> [ BLANK ] <<<%d %d-B", wMiescie[0], wKolejceA, wKolejceB, wMiescie[1]);
printf("\nA-%d %d>>> [>> %d >>] <<<%d %d-B", wMiescie[0], wKolejceA, numerWatku, wKolejceB, wMiescie[1]);
pthread_mutex_unlock(&scrLock);
break;
} else
pthread_cond_wait(&warKolejki, &most);
} while (1);
pthread_mutex_unlock(&most);
sleep(1);
jedzNaMiasto(numerWatku, 1);
}
void bDoA(int numerWatku, int miasto) {
pthread_mutex_lock(&most);
do {
if (pierwszyWKolejce(numerWatku, miasto) == 1) {
pthread_mutex_lock(&miasto);
pthread_mutex_lock(&scrLock);
wKolejceB--;
usunZKolejki(numerWatku, miasto);
pthread_mutex_unlock(&miasto);
printf("\nA-%d %d>>> [ BLANK ] <<<%d %d-B", wMiescie[0], wKolejceA, wKolejceB, wMiescie[1]);
printf("\nA-%d %d>>> [<< %d <<] <<<%d %d-B", wMiescie[0], wKolejceA, numerWatku, wKolejceB, wMiescie[1]);
pthread_mutex_unlock(&scrLock);
break;
} else
pthread_cond_wait(&warKolejki, &most);
} while (1);
pthread_mutex_unlock(&most);
sleep(1);
jedzNaMiasto(numerWatku, 0);
}
int losujMiasto() {
int losowa = rand() % 100;
if (losowa % 2 == 0) {
return 0; // Miasto A
} else {
return 1; // Miasto B
}
}
void *inicjujWatek(int numerWatku) //DOdaj inny mutex zamiast obecnych
{
int losoweMiasto = losujMiasto();
if (losoweMiasto == 0) {
pthread_mutex_lock(&miasto);
wKolejceA++;
dodajDoKolejki(numerWatku, losoweMiasto, 1);
pthread_mutex_unlock(&miasto);
while (ilWatkow < lSamochodow);
aDoB(numerWatku, losoweMiasto);
}
else if (losoweMiasto == 1) {
pthread_mutex_lock(&miasto);
wKolejceB++;
dodajDoKolejki(numerWatku, losoweMiasto, 1);
pthread_mutex_unlock(&miasto);
while (ilWatkow < lSamochodow);
bDoA(numerWatku, losoweMiasto);
}
}
void utworzWatki() {
pthread_t samochod[lSamochodow];
int i;
for (i = 0; i < lSamochodow; i++) {
int wynik = pthread_create(&samochod[i], NULL, &inicjujWatek, (void *) i + 1); //!!!!!!!!!!!!!
if (wynik != 0) printf("Nie powiodło się pthread_create\n");
else ilWatkow++;
}
for (i = 0; i < lSamochodow; i++) {
pthread_join(samochod[i], NULL);
}
}
void ilSamochodow(char *arg) // Parsuje liczbe samochodow z parametru
{
int rozmiarArg = 1;
while (arg[rozmiarArg] != '\0') {
rozmiarArg++;
}
char temp[rozmiarArg];
int indArg = 1;
int indTemp = 0;
for (indArg = 1; indArg < rozmiarArg; indArg++) {
temp[indTemp] = arg[indArg];
indTemp++;
}
temp[indTemp] = '\0';
lSamochodow = atoi(temp);
printf("\nLiczba samochodow z parametru = %d", lSamochodow);
}
void sprDebug(int argc, char **argv) // Sprawdza czy podano parametr -debug
{
if (argc > 2) {
if (strcmp(argv[2], "-debug") == 0) {
trybDebug = 1;
printf("\nTryb debug");
}
}
}
void zerowanieZmiennych() {
wKolejceA = 0;
wKolejceB = 0;
wMiescie[0] = 0;
wMiescie[1] = 0;
int i;
for (i = 0; i < lSamochodow; i++) {
kolejkaA[i] = 0;
kolejkaB[i] = 0;
}
}
int main(int argc, char **argv) {
printf("KOMPILACJA: gcc -o most most2.c -lpthread");
printf("\nUruchamianie: ./most -N -debug");
pthread_mutex_init(&most, NULL);
pthread_mutex_init(&miasto, NULL);
//pthread_mutex_init(&miasto, NULL);
pthread_mutex_init(&scrLock, NULL);
int kolejkawA[lSamochodow];
int kolejkawB[lSamochodow];
kolejkaA = kolejkawA;
kolejkaB = kolejkawB;
ilSamochodow(argv[1]);
zerowanieZmiennych();
sprDebug(argc, argv);
utworzWatki();
return 0;
}
C 
Linux 
Shalom