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

С++ для начинающих

Войти
Регистрация
Восстановить пароль
 
keyne
0 / 0 / 0
Регистрация: 03.02.2014
Сообщений: 4
#1

Обращение трех потоков к очереди - C++

03.02.2014, 10:35. Просмотров 344. Ответов 4
Метки нет (Все метки)

Помогите разобраться
Три различных потока исполнения в одной программе независимо друг от друга обращаются к очереди:


C++
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
#include <boost/thread.hpp>
#include <iostream>
#include <queue>
 
 
std::queue<char> the_queue;
 
 
void producer() {
        while(true) {
                char a = cin.get();
                the_queue.push(a);
        }
}
 
 
void concumer() {
        while(true) {
                if ( the_queue.size() > 0 ) {
                        char& a = the_queue.front();
                        std::cout << a;
                        the_queue().pop();
                }
        }
}
 
 
int main() {
        boost::thread p1(producer);
        boost::thread p2(producer);
        boost::thread c1(consumer);
        boost::thread::join_all();
}
Что неправильно в этой программе? Дайте исправленный вариант.
Лучшие ответы (1)
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
03.02.2014, 10:35     Обращение трех потоков к очереди
Посмотрите здесь:

Очереди на С C++
C++ Очереди
C++ Очереди
Счастливый билет (сумма первых трех цифр равна сумме последних трех) C++
Очереди C++
Очереди в С++ C++
Очереди (С++) C++
C++ Функция: получить шестизначное число и проверить, равна ли сумма первых трех цифр сумме последних трех
Ввести урожайность трех сортов пшеницы (36, 40, 44 т/га) и размеры трех соответственных по- лей (у га). Скольк C++
Обращение многих потоков к одному файлу C++
Обращение к переменной из разных потоков C++
C++ Переменной d присвоить наибольшее из трех чисел, а переменной s наименьшее из трех чисел.

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

Или воспользуйтесь поиском по форуму:
После регистрации реклама в сообщениях будет скрыта и будут доступны все возможности форума.
aLarman
641 / 562 / 89
Регистрация: 13.12.2012
Сообщений: 2,109
03.02.2014, 10:45     Обращение трех потоков к очереди #2
Цитата Сообщение от keyne Посмотреть сообщение
Что неправильно в этой программе?
может то что они обращаются на общий ресурс, может необходимы мьютексы?
DiffEreD
1427 / 764 / 95
Регистрация: 21.06.2011
Сообщений: 1,740
Записей в блоге: 2
03.02.2014, 12:34     Обращение трех потоков к очереди #3
Сообщение было отмечено автором темы, экспертом или модератором как ответ
Можно мютексы, можно boost::lockfree если уж буст используется:
C++
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
#include <boost/thread.hpp>
#include <iostream>
#include <queue>
#include <boost/lockfree/queue.hpp>
 
//std::queue<char> the_queue;
boost::lockfree::queue<char> the_queue(128);
 
void producer() {
   while(true) {
      char a = std::cin.get();
      std::cin.ignore();
      the_queue.push(a);
   }
}
 
 
void concumer() {
   while(true) {
      if ( !the_queue.empty()) {
         char a;
         the_queue.pop(a);
         std::cout << a << "\n";
      }
   }
}
 
 
int main() {
   boost::thread_group threads;
   threads.create_thread(&producer);
   threads.create_thread(&concumer);
 
   threads.join_all();
}
Добавлено через 57 секунд
А читать двумя потоками с консоли как то не красиво получается.

Добавлено через 14 минут
На мютексах что типа такого:
C++
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
#include <boost/thread.hpp>
#include <iostream>
#include <queue>
#include <mutex>
 
std::queue<char> the_queue;
std::mutex m;
 
void producer() {
   while(true) {
      char a = std::cin.get();
      std::lock_guard<std::mutex> locker(m);
      the_queue.push(a);
   }
}
 
 
void concumer() {
   while(true) {
      std::lock_guard<std::mutex> locker(m);
      while ( !the_queue.empty()) {
         char a = the_queue.front();
         the_queue.pop();
         std::cout << a << "\n";
      }
   }
}
 
 
int main() {
   boost::thread_group threads;
   threads.create_thread(&producer);
   threads.create_thread(&concumer);
 
   threads.join_all();
}
Убежденный
Системный программист
Эксперт С++
15173 / 6805 / 1073
Регистрация: 02.05.2013
Сообщений: 11,118
Завершенные тесты: 1
03.02.2014, 12:34     Обращение трех потоков к очереди #4
Цитата Сообщение от keyne Посмотреть сообщение
Что неправильно в этой программе?
1) Нет синхронизации доступа к очереди (решение уже написали).

2) while(true) - это холостой цикл, который впустую расходует процессорные ресурсы.
Например, на двухъядерном компе вы получите постоянную загрузку CPU в 50%.

C++
1
2
3
4
5
6
7
8
9
void concumer() {
   while(true) {
      if ( !the_queue.empty()) {
         char a;
         the_queue.pop(a);
         std::cout << a << "\n";
      }
   }
}
В данном конкретном случае это не опасно, т.к. producer только добавляет
новые элементы в очередь. Но если, к примеру, добавить еще одного
consumer-а, получим гонки (если кто-то очистит очередь между empty и pop).
keyne
0 / 0 / 0
Регистрация: 03.02.2014
Сообщений: 4
03.02.2014, 14:16  [ТС]     Обращение трех потоков к очереди #5
Всем спасибо за ответы!
Yandex
Объявления
03.02.2014, 14:16     Обращение трех потоков к очереди
Ответ Создать тему
Опции темы

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2017, vBulletin Solutions, Inc.
Рейтинг@Mail.ru