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

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

Ранее никогда с потоками дело не имел, не знаю толком никакой теории(если можно, посоветуйте конкретные примеры для быстрого освоения). Существует задача: в одном потоке к некой общей строке что-то прибавляется, а в другом потоке мониторится длина этой строки, и при достижении длины, допустим в 500 символов строка отчищается. Вычитал, что нужен mutex(не понял толком, что это; понял, что это какой-то простейший синхронизатор), но не знаю как применить. Грубая накидка кода.

C++

#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++

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

Ilot · 01.07.2014, 13:55

В п. 4.1.1 практически аккурат ваш пример.

Добавлено через 7 минут
Вот рабочий пример. Если это то что вы хотели?...

C++

#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++

#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++

#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/

Croessmah Неэпический 17807 / 10579 / 2042 Регистрация: 27.09.2012 Сообщений: 26,609 Записей в блоге: 1
	01.07.2014, 12:55	2
	Сообщение от petr_shumilov если можно, посоветуйте конкретные примеры для быстрого освоения на счет быстрого не знаю, но вот http://www.ozon.ru/context/detail/id/17636939/ 0

@0x10 3254 / 2056 / 351 Регистрация: 24.11.2012 Сообщений: 4,909
	01.07.2014, 13:28	3
	Сообщение от petr_shumilov ычитал, что нужен mutex(не понял толком, что это; понял, что это какой-то простейший синхронизатор), но не знаю как применить http://en.cppreference.com/w/cpp/thread/mutex 0

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

Ilot $Эксперт по математике/физике$ 2004 / 1335 / 379 Регистрация: 16.05.2013 Сообщений: 3,454 Записей в блоге: 6
	01.07.2014, 13:38	5
	Есть замечательная книга по потокам в 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 [ТС]	8
	Всё разобрался 0

@nmcf 7376 / 6295 / 2859 Регистрация: 14.04.2014 Сообщений: 27,297
	01.07.2014, 14:05	9
	Цикл while(true) добавь в поток, как у Ilot в примере. 0

Ilot
	01.07.2014, 14:14 #10
	Не по теме: Сообщение от petr_shumilov Всё разобрался Я тоже так хочу, а то мне для понимания потоков несколько недель потребовалось и то не думаю, что уверенно себя в них чувствую.:D 0

@petr_shumilov 0 / 0 / 0 Регистрация: 01.07.2014 Сообщений: 7
	01.07.2014, 14:23 [ТС]	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 0

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

Опции темы