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

@petr_shumilov · Регистрация: 01.07.2014

Студворк — интернет-сервис помощи студентам

Ранее никогда с потоками дело не имел, не знаю толком никакой теории(если можно, посоветуйте конкретные примеры для быстрого освоения). Существует задача: в одном потоке к некой общей строке что-то прибавляется, а в другом потоке мониторится длина этой строки, и при достижении длины, допустим в 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;
}

Прошу вашей помощи в доработке, в советах на будущее, в понятии философии потоков...

Croessmah · 01.07.2014, 12:55

Сообщение от petr_shumilov

если можно, посоветуйте конкретные примеры для быстрого освоения

на счет быстрого не знаю, но вот http://www.ozon.ru/context/detail/id/17636939/

@0x10 · 01.07.2014, 13:28

Сообщение от petr_shumilov

ычитал, что нужен mutex(не понял толком, что это; понял, что это какой-то простейший синхронизатор), но не знаю как применить

http://en.cppreference.com/w/cpp/thread/mutex

@petr_shumilov · 01.07.2014, 13:34 **[ТС]**

Типичный ответ на русском форуме. Конечно я первым делом сгонял на референс, однако обычно я не читаю там теории из-за плохого знания английского, а просто беру код примеров. Я прошу, чтоб вы "разжували". Как мне доработать приведённый выше код??

Ilot · 01.07.2014, 13:38

Есть замечательная книга по потокам в C++11
Э. Уильямс Параллельное программирование на С++ в действии.
http://www.ozon.ru/context/detail/id/17636939/
Советую ознакомится.
В данном случае вам думаю следует смотреть не в сторону мьютексов, а по большей части condition_variable.

@nmcf · 01.07.2014, 13:46

В простейшем случае так:

C++
1
2
3
4
5
mutex m;
// В каждом потоке:
m.lock();
// Здесь обращение к данным
m.unlock()

Ilot · 01.07.2014, 13:55

В п. 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 · 01.07.2014, 14:03 **[ТС]**

Всё разобрался

@nmcf · 01.07.2014, 14:05

Цикл while(true) добавь в поток, как у Ilot в примере.

Ilot · 01.07.2014, 14:14

Не по теме:

Сообщение от petr_shumilov

Всё разобрался

Я тоже так хочу, а то мне для понимания потоков несколько недель потребовалось и то не думаю, что уверенно себя в них чувствую.:D

@DrOffset · 01.07.2014, 14:21

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 · 01.07.2014, 14:23 **[ТС]**

Что-то у меня не работает, как слепой котёнок я в потоках. Я хочу добиться результата при котором будет вот такой вывод:

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 · 01.07.2014, 14:28

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 · 01.07.2014, 15:48

а как же хабра? http://habrahabr.ru/post/182610/

Новые блоги и статьи Все статьи Все блоги /
BOINC: 22 года — и всё ещё работает Programma_Boinc 12.03.2026 BOINC: 22 года — и всё ещё работает Дэвид Андерсон написал ретроспективу. Кратко: в 2001 году он ушёл из United Devices, где был CTO, и за несколько месяцев написал ядро BOINC — клиент, сервер,. . .	SDL3 для Desktop (MinGW): Создаём пустое окно с нуля для 2D-графики на SDL3, Си и C++ 8Observer8 10.03.2026 Содержание блога Финальные проекты на Си и на C++: hello-sdl3-c. zip hello-sdl3-cpp. zip Результат:	Установка CMake и MinGW 13.1 для сборки С и C++ приложений из консоли и из Qt Creator в EXE 8Observer8 10.03.2026 Содержание блога MinGW - это коллекция инструментов для сборки приложений в EXE. CMake - это система сборки приложений. Здесь описаны базовые шаги для старта программирования с помощью CMake и. . .	Как дизайн сайта влияет на конверсию: 7 решений, которые реально повышают заявки Neotwalker 08.03.2026 Многие до сих пор воспринимают дизайн сайта как “красивую оболочку”. На практике всё иначе: дизайн напрямую влияет на то, оставит человек заявку или уйдёт через несколько секунд. Даже если у вас. . .
Модульная разработка через nuget packages DevAlt 07.03.2026 Сложившийся в . Net-среде способ разработки чаще всего предполагает монорепозиторий в котором находятся все исходники. При создании нового решения, мы просто добавляем нужные проекты и имеем. . .	Модульный подход на примере F# DevAlt 06.03.2026 В блоге дяди Боба наткнулся на такое определение: В этой книге («Подход, основанный на вариантах использования») Ивар утверждает, что архитектура программного обеспечения — это структуры,. . .	Управление камерой с помощью скрипта OrbitControls.js на Three.js: Вращение, зум и панорамирование 8Observer8 05.03.2026 Содержание блога Финальная демка в браузере работает на Desktop и мобильных браузерах. Итоговый код: orbit-controls-threejs-js. zip. Сканируйте QR-код на мобильном. Вращайте камеру одним пальцем,. . .	SDL3 для Web (WebAssembly): Синхронизация спрайтов SDL3 и тел Box2D 8Observer8 04.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-sync-physics-sprites-sdl3-c. zip На первой гифке отладочные линии отключены, а на второй включены:. . .

@petr_shumilov 0 / 0 / 0 Регистрация: 01.07.2014 Сообщений: 7
	01.07.2014, 13:34 [ТС]
	Типичный ответ на русском форуме. Конечно я первым делом сгонял на референс, однако обычно я не читаю там теории из-за плохого знания английского, а просто беру код примеров. Я прошу, чтоб вы "разжували". Как мне доработать приведённый выше код?? 0

Ilot $Эксперт по математике/физике$ 2224 / 1426 / 420 Регистрация: 16.05.2013 Сообщений: 3,646 Записей в блоге: 6
	01.07.2014, 13:38
	Есть замечательная книга по потокам в C++11 Э. Уильямс Параллельное программирование на С++ в действии. http://www.ozon.ru/context/detail/id/17636939/ Советую ознакомится. В данном случае вам думаю следует смотреть не в сторону мьютексов, а по большей части condition_variable. 1

@petr_shumilov 0 / 0 / 0 Регистрация: 01.07.2014 Сообщений: 7
	01.07.2014, 14:03 [ТС]
	Всё разобрался 0

@nmcf 7804 / 6568 / 2988 Регистрация: 14.04.2014 Сообщений: 28,705
	01.07.2014, 14:05
	Цикл while(true) добавь в поток, как у Ilot в примере. 0

@petr_shumilov 0 / 0 / 0 Регистрация: 01.07.2014 Сообщений: 7
	01.07.2014, 14:23 [ТС]
	Что-то у меня не работает, как слепой котёнок я в потоках. Я хочу добиться результата при котором будет вот такой вывод: 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 0

@Friday ну и долго меня небыло... 61 / 57 / 8 Регистрация: 24.03.2013 Сообщений: 173
	01.07.2014, 15:48
	а как же хабра? http://habrahabr.ru/post/182610/ 0