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

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

Восстановить пароль Регистрация
 
keyne
0 / 0 / 0
Регистрация: 03.02.2014
Сообщений: 4
03.02.2014, 10:35     Обращение трех потоков к очереди #1
Помогите разобраться
Три различных потока исполнения в одной программе независимо друг от друга обращаются к очереди:


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++ Подсчитать количество "счастливых" шестизначных автобусных билетов(сумма первых трех цифр равна сумме трех последних цифр)
После регистрации реклама в сообщениях будет скрыта и будут доступны все возможности форума.
aLarman
636 / 557 / 89
Регистрация: 13.12.2012
Сообщений: 2,109
03.02.2014, 10:45     Обращение трех потоков к очереди #2
Цитата Сообщение от keyne Посмотреть сообщение
Что неправильно в этой программе?
может то что они обращаются на общий ресурс, может необходимы мьютексы?
DiffEreD
 Аватар для DiffEreD
1420 / 757 / 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();
}
Убежденный
Системный программист
 Аватар для Убежденный
14216 / 6231 / 988
Регистрация: 02.05.2013
Сообщений: 10,390
Завершенные тесты: 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     Обращение трех потоков к очереди
Ответ Создать тему
Опции темы

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