170 похожих чатов

Вот мой код, тут всего 80 строчек, может кто подскажет

в чем проблема?
У меня код работает отлично в 100% случаев, у друга ломается через раз, у обоих убунта 20.04
pthread_rwlock_t rwlock;

void* reader(void*) {
int val;
int count = 0;

while (ongoing) {
check(pthread_rwlock_rdlock(&rwlock));
if (!ongoing)
return NULL;

count++;
printf("Reader guess it is %d \n", val = rand() % 9 + 1);
if (val == var) {
printf("Reader win! Attempts: %d \n", count);
ongoing = false;
}

check(pthread_rwlock_unlock(&rwlock));
while (ongoing && !pthread_rwlock_tryrdlock(&rwlock))
pthread_rwlock_unlock(&rwlock);
}

check(pthread_rwlock_unlock(&rwlock));
while (ongoing && !pthread_rwlock_tryrdlock(&rwlock))
pthread_rwlock_unlock(&rwlock);

return NULL;
}

void* writer(void*) {
printf("Right number is %d \n", var = rand() % 10 + 1);
for (int i = 0; i < 10 && ongoing; ++i) {
check(pthread_rwlock_unlock(&rwlock));
while (!pthread_rwlock_trywrlock(&rwlock))
pthread_rwlock_unlock(&rwlock);
check(pthread_rwlock_wrlock(&rwlock));
}
ongoing = false;
printf("Writer ends the game \n\n");
check(pthread_rwlock_unlock(&rwlock));
}

void play(int value) {
pthread_t t;
bool f = true;

for (int i = 0; i < value; i++) {
ongoing = true;
check(pthread_rwlock_init(&rwlock, NULL));
if (f) {
check(pthread_rwlock_wrlock(&rwlock));
check(pthread_create(&t, NULL, reader, NULL));
writer(NULL);
} else {
check(pthread_rwlock_rdlock(&rwlock));
check(pthread_create(&t, NULL, writer, NULL));
reader(NULL);
}
check(pthread_join(t, NULL));
check(pthread_rwlock_destroy(&rwlock));
f = !f;
}
}

int main() {
srand(time(NULL));
play(3);
}

21 ответов

17 просмотров
G6- Автор вопроса

запускаю в онлайн компиляторе и тоже всё работает, может у друга с убунтой что то не так? Но я двух знакомых просил, у обоих косячно работает, у меня одного всё нормально

Лучше было б на pastebin...

Ща поглядим

G6- Автор вопроса
Ilya Zviagin
Лучше было б на pastebin...

сори, не пользовался песочницами для плюсов, учту

G6
запускаю в онлайн компиляторе и тоже всё работает,...

Код без хотя бы одного #include... Шли полный код, шли через paste bin, это даже не скомпилировать

Скорее всего тут просто гонки между потоками...

А что за on going?

G6
Что это значит?)

Тогда точно гонки, раз не знаешь...

G6- Автор вопроса
Ilya Zviagin
А что за on going?

булевское просто, чтобы вайл работал в reader, а когда цикл в writer заканчивается - ongoing = false

G6
булевское просто, чтобы вайл работал в reader, а к...

Доступ К общим данным потоков надо синхронизировать, так нельзя писать, будут гонки (data race). Несогласованный доступ потоков к общим переменным.

G6
булевское просто, чтобы вайл работал в reader, а к...

Энтони Уильямс, Параллельное программирование в С++, целая книга, читай

G6- Автор вопроса
Ilya Zviagin
Энтони Уильямс, Параллельное программирование в С+...

преподаватель в вузе ничего об этом в примере не написал)) спасибо большое, пойду почитаю

G6
булевское просто, чтобы вайл работал в reader, а к...

Твой ongoing должен быть как минимум atomic variable, или защищен мьютексом или другими примитивами синхронизации потоков. А в таком виде это UB, и так оно и работает. У тебя случайно да, у друга нет

G6- Автор вопроса
Ilya Zviagin
А вы проходили многопоточность?

у нас это как отдельный предмет - прикладное программирование, поэтому всё очень сжато объясняют

G6- Автор вопроса
Ilya Zviagin
А вы проходили многопоточность?

сказали вот так можно поток сделать, вот так удалить и пару слов как им друг друга подождать

G6
сказали вот так можно поток сделать, вот так удали...

Это значит вы это не проходили. Так что не стоило браться за такие программы, хоть и с виду оно выглядит просто...

G6- Автор вопроса
Ilya Zviagin
Это значит вы это не проходили. Так что не стоило...

да, выглядело действительно просто, зато в итоге 4 часа сидел, пока Вы не подсказали)

Похожие вопросы

Обсуждают сегодня

Какой-то там пердун в 90-х решил, что есть какая-то разная типизация. Кого вообще это волнует?
КТ315
49
void terminal_scroll() { memmove(terminal_buffer, terminal_buffer + VGA_WIDTH, buffer_size - VGA_WIDTH); memset(terminal_buffer + buffer_size - VGA_WIDTH, 0, VGA_WIDTH); ...
Егор
47
Всем привет! Подскажите, пожалуйста, в чем ошибка? Настраиваю подключение к MySQL. Либы лежат рядом с exe. Все как по "учебнику"
Евгений
16
А можете как-то проверить меня по знаниям по ассемблеру?
A A
132
Здравствуйте! У меня появилась возможность купить книгу "Изучай Haskell во имя добра!". Но я где-то слышал, что эта книга устарела. Насколько это правда??
E
22
Здравствуйте! Я вот на stepic решаю задачи на хаскеле https://stepik.org/lesson/8443/step/8?unit=1578 мой код import Data.List (isInfixOf) removing :: String -> [String] ->...
E
10
Камрады, кто тесно работал с vtv, хотел уточнить. Ширина column задаётся жёстко на этапе создания дерева или можно в рантайме ее менять программно (не мышкой)?
Ed Doc
10
да ладно ... что там неочевидного ? глянуть в исх-ки датасета и/или кверика чтобы понять в каком месте и как выполняется обращения к св-вам blablaSQL - минутное дело, даже е...
Сергей
7
Здесь для arm кто-нибудь кодит ?
Nothing
52
Всем привет, у меня есть сервер принимающий входящие HTTP подключения, как проверить, что подключение было через прокси или нет, есть какие то поля в заголовках по которым мо...
DS
8
Карта сайта