Форум программистов, компьютерный форум CyberForum.ru

Мьютексы. Синхронизация потоков - C++

Восстановить пароль Регистрация
 
DonatOshchepkov
0 / 0 / 0
Регистрация: 12.05.2014
Сообщений: 4
24.05.2014, 16:50     Мьютексы. Синхронизация потоков #1
Всем известная задача про философов. Помогите найти ошибку) Заранее благодарен

C++ (Qt)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
#include <iostream>
#include <pthread.h>
#include <semaphore.h>
#include <cstdlib>     /* srand, rand */
#include <ctime>       /* time */
 
using namespace std;
 
const int amountP = 13; //philosopher
bool forks[amountP];
 
pthread_mutex_t mutChair[amountP]; //mutex chair
 
 
bool goToSetWaiter(const int numMan){
 
    int leftNum = (amountP + numMan - 1) % amountP;
    int rightNum = (amountP + numMan + 1) % amountP;
 
    bool fl = (!forks[leftNum] && !forks[rightNum]);
    if( fl ){
        forks[leftNum] = true;
        forks[rightNum] = true;
 
        cout << "food " << numMan << endl;
    }
 
    return fl;
}
 
void goToGetWaiter(const int numMan){
 
    int leftNum = (amountP + numMan - 1) % amountP;
    int rightNum = (amountP + numMan + 1) % amountP;
 
    forks[leftNum] = false;
    forks[rightNum] = false;
 
    cout << "exit " << numMan << endl;
 
}
 
void *ingestion(void *arg){
    const int numberMan = rand() % amountP; //у каждого какой то свой номер
    pthread_mutex_lock(&mutChair[numberMan]); //сел на стул
 
    bool fl;
    do{
        fl = goToSetWaiter(numberMan);
    }
    while( !fl ); //официант разрулит кто может есть, а кто нет, остальные ждут официанта, кому тот не может выдать 2 вилки
 
    
    goToGetWaiter(numberMan); //после того как поели отдают официанту указ забрать вилки
    pthread_mutex_unlock(&mutChair[numberMan]); //встал со стула
 
    return NULL;
}
 
int main()
{
    /* initialize random seed: */
    srand (time(NULL));
 
    pthread_t thread[amountP];
    int num[amountP];
 
    for(int i = 0; i < amountP; ++i){
        forks[i] = false;
    }
 
    while( true ){
        for(int i = 0; i < amountP; ++i){ //пусть по 5 философов заходят
            pthread_create(&thread[i], NULL, ingestion, NULL);
        }
 
        for(int i = 0; i < amountP; ++i)
            pthread_join(thread[i], NULL);
    }
 
    return 0;
}
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
24.05.2014, 16:50     Мьютексы. Синхронизация потоков
Посмотрите здесь:

C++ Синхронизация потоков средствами WinAPI.
C++ Синхронизация потоков, события, WinAPI
C++ Синхронизация потоков в c++
Синхронизация потоков на семафорах C++
Понятие синхронизации потоков и процессов. Семафоры и мьютексы C++
C++ Буферы и синхронизация потоков
Синхронизация потоков - уведомление о событии C++
Синхронизация потоков C++

Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
После регистрации реклама в сообщениях будет скрыта и будут доступны все возможности форума.
Ответ Создать тему
Опции темы

Текущее время: 05:55. Часовой пояс GMT +3.
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2016, vBulletin Solutions, Inc.
Рейтинг@Mail.ru