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

С++ 11 потоки для начинающих - C++

Восстановить пароль Регистрация
 
petr_shumilov
0 / 0 / 0
Регистрация: 01.07.2014
Сообщений: 7
01.07.2014, 12:53     С++ 11 потоки для начинающих #1
Ранее никогда с потоками дело не имел, не знаю толком никакой теории(если можно, посоветуйте конкретные примеры для быстрого освоения). Существует задача: в одном потоке к некой общей строке что-то прибавляется, а в другом потоке мониторится длина этой строки, и при достижении длины, допустим в 500 символов строка отчищается. Вычитал, что нужен mutex(не понял толком, что это; понял, что это какой-то простейший синхронизатор), но не знаю как применить. Грубая накидка кода.
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
#include <iostream>
#include <thread>
#include <stdlib.h>
#include <cstring>
 
std::string glob = "";
 
void thread_addition()
{
    while (1)
    {
        glob += "ab";
        std::cout << "additional_thread -- " << glob << "\n";
        sleep(3);
    }
}
 
void thread_monitoring()
{
    if (glob.size() > 500)
        glob = "";
}
 
 
int main()
{
     std::thread additor(thread_addition);
     std::thread monitor(thread_monitoring);
     additor.join();
     monitor.join();
     return 0;
}
Прошу вашей помощи в доработке, в советах на будущее, в понятии философии потоков...
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
01.07.2014, 12:53     С++ 11 потоки для начинающих
Посмотрите здесь:

C++ С/С++ для начинающих
Помогите найти ошибку C++

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

Или воспользуйтесь поиском по форуму:
После регистрации реклама в сообщениях будет скрыта и будут доступны все возможности форума.
Croessmah
Модератор
Эксперт С++
 Аватар для Croessmah
11828 / 6807 / 769
Регистрация: 27.09.2012
Сообщений: 16,878
Записей в блоге: 2
Завершенные тесты: 1
01.07.2014, 12:55     С++ 11 потоки для начинающих #2
Цитата Сообщение от petr_shumilov Посмотреть сообщение
если можно, посоветуйте конкретные примеры для быстрого освоения
на счет быстрого не знаю, но вот http://www.ozon.ru/context/detail/id/17636939/
0x10
2425 / 1597 / 232
Регистрация: 24.11.2012
Сообщений: 3,919
01.07.2014, 13:28     С++ 11 потоки для начинающих #3
Цитата Сообщение от petr_shumilov Посмотреть сообщение
ычитал, что нужен mutex(не понял толком, что это; понял, что это какой-то простейший синхронизатор), но не знаю как применить
http://en.cppreference.com/w/cpp/thread/mutex
petr_shumilov
0 / 0 / 0
Регистрация: 01.07.2014
Сообщений: 7
01.07.2014, 13:34  [ТС]     С++ 11 потоки для начинающих #4
Типичный ответ на русском форуме. Конечно я первым делом сгонял на референс, однако обычно я не читаю там теории из-за плохого знания английского, а просто беру код примеров. Я прошу, чтоб вы "разжували". Как мне доработать приведённый выше код??
Ilot
Модератор
Эксперт С++
1767 / 1142 / 223
Регистрация: 16.05.2013
Сообщений: 3,020
Записей в блоге: 5
Завершенные тесты: 1
01.07.2014, 13:38     С++ 11 потоки для начинающих #5
Есть замечательная книга по потокам в C++11
Э. Уильямс Параллельное программирование на С++ в действии.
http://www.ozon.ru/context/detail/id/17636939/
Советую ознакомится.
В данном случае вам думаю следует смотреть не в сторону мьютексов, а по большей части condition_variable.
nmcf
4298 / 3719 / 1252
Регистрация: 14.04.2014
Сообщений: 14,542
01.07.2014, 13:46     С++ 11 потоки для начинающих #6
В простейшем случае так:
C++
1
2
3
4
5
mutex m;
// В каждом потоке:
m.lock();
// Здесь обращение к данным
m.unlock()
Ilot
Модератор
Эксперт С++
1767 / 1142 / 223
Регистрация: 16.05.2013
Сообщений: 3,020
Записей в блоге: 5
Завершенные тесты: 1
01.07.2014, 13:55     С++ 11 потоки для начинающих #7
В п. 4.1.1 практически аккурат ваш пример.

Добавлено через 7 минут
Вот рабочий пример. Если это то что вы хотели?...
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
37
38
39
40
41
#include <iostream>
#include <thread>
#include <string>
#include <windows.h>
#include <mutex>
#include <condition_variable>
 
std::string glob = "";
std::condition_variable monitoring;
std::mutex mut;
void thread_addition()
{
    while (true)
    {
        std::lock_guard<std::mutex> lk(mut);
        glob += "ab";
        std::cout << "additional_thread -- " << glob << "\n";
        monitoring.notify_one();
        Sleep(100);
    }
}
 
void thread_monitoring()
{
    while(true) {
        std::unique_lock<std::mutex> lk(mut);
        monitoring.wait(lk, [](){ return glob.size() > 50; });
        glob = "";
    }
 
}
 
 
int main()
{
     std::thread additor(thread_addition);
     std::thread monitor(thread_monitoring);
     additor.join();
     monitor.join();
     return 0;
}
petr_shumilov
0 / 0 / 0
Регистрация: 01.07.2014
Сообщений: 7
01.07.2014, 14:03  [ТС]     С++ 11 потоки для начинающих #8
Всё разобрался
nmcf
4298 / 3719 / 1252
Регистрация: 14.04.2014
Сообщений: 14,542
01.07.2014, 14:05     С++ 11 потоки для начинающих #9
Цикл while(true) добавь в поток, как у Ilot в примере.
Ilot
01.07.2014, 14:14
  #10

Не по теме:

Цитата Сообщение от petr_shumilov Посмотреть сообщение
Всё разобрался
Я тоже так хочу, а то мне для понимания потоков несколько недель потребовалось и то не думаю, что уверенно себя в них чувствую.

DrOffset
6428 / 3802 / 882
Регистрация: 30.01.2014
Сообщений: 6,601
01.07.2014, 14:21     С++ 11 потоки для начинающих #11
petr_shumilov,
Вариант с возможностью нормального выхода:
Кликните здесь для просмотра всего текста
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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
#include <cstdio>
#include <thread>
#include <mutex>
#include <condition_variable>
 
int main()
{
    std::string str;
    std::mutex  m;
    std::condition_variable cond;
 
    bool done = false;
 
    std::thread producer([&]()
        {
            for (int i = 0; i < 10; ++i)
            {
                std::this_thread::sleep_for(std::chrono::seconds(1));
                std::unique_lock<std::mutex> lock(m);
 
                str += "abcdef";
                printf("Pushing to string... Length %d\n", str.length());
                cond.notify_one();
            }
 
            std::unique_lock<std::mutex> lock(m);
            done = true;
            cond.notify_one();
        }
    );
 
    std::thread consumer([&]()
        {
            while(1)
            {
                std::unique_lock<std::mutex> lock(m);
                while(!done && str.length() < 50)
                {
                    cond.wait(lock);
                }
                if(done)
                {
                    break;
                }
                str.clear();
                printf("Cleaning...\n");
            }
        }
    );
 
    producer.join();
    consumer.join();
}
petr_shumilov
0 / 0 / 0
Регистрация: 01.07.2014
Сообщений: 7
01.07.2014, 14:23  [ТС]     С++ 11 потоки для начинающих #12
Что-то у меня не работает, как слепой котёнок я в потоках. Я хочу добиться результата при котором будет вот такой вывод:

additional_thread -- ab
additional_thread -- abab
additional_thread -- ababab
additional_thread -- abababab
additional_thread -- ababababab
additional_thread -- ab
additional_thread -- abab
additional_thread -- ababab
additional_thread -- abababab
additional_thread -- ababababab
при условии, что количество символов, при котором строка отчищается 10
DrOffset
6428 / 3802 / 882
Регистрация: 30.01.2014
Сообщений: 6,601
01.07.2014, 14:28     С++ 11 потоки для начинающих #13
petr_shumilov,
Кликните здесь для просмотра всего текста
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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
#include <cstdio>
#include <thread>
#include <mutex>
#include <condition_variable>
 
int main()
{
    std::string str;
    std::mutex  m;
    std::condition_variable cond;
 
    bool done = false;
 
    std::thread producer([&]()
        {
            for (int i = 0; i < 30; ++i)
            {
                std::this_thread::sleep_for(std::chrono::seconds(1));
                std::unique_lock<std::mutex> lock(m);
 
                str += "ab";
                printf("%s\n", str.c_str());
                cond.notify_one();
            }
 
            std::unique_lock<std::mutex> lock(m);
            done = true;
            cond.notify_one();
        }
    );
 
    std::thread consumer([&]()
        {
            while(1)
            {
                std::unique_lock<std::mutex> lock(m);
                while(!done && str.length() < 10)
                {
                    cond.wait(lock);
                }
                if(done)
                {
                    break;
                }
                str.clear();
            }
        }
    );
 
    producer.join();
    consumer.join();
}
Friday
ну и долго меня небыло...
 Аватар для Friday
61 / 57 / 8
Регистрация: 24.03.2013
Сообщений: 173
01.07.2014, 15:48     С++ 11 потоки для начинающих #14
а как же хабра? http://habrahabr.ru/post/182610/
Yandex
Объявления
01.07.2014, 15:48     С++ 11 потоки для начинающих
Ответ Создать тему
Опции темы

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