Как работать с переменной в нескольких потоках? - C++

@MastAKK · Регистрация: 13.10.2012

Собственно, вся суть в названии темы. Подскажите, как я могу изменить переменную в дочерних потоках так, чтобы она изменялась и в основном?

@DrOffset · 17.08.2014, 00:41

Хабр конечно не самый лучший источник информации, но представление определенное получишь. В любом случае проще прочитать там, чем сейчас тут целую статью писать

@MastAKK · 17.08.2014, 00:45 **[ТС]**

DrOffset, ну что же, действительно, придётся почитать хабр. Может и тонкости какие узнаю.
Благодарб за ссылку

@Andrej · 17.08.2014, 00:45

Bash

1	clang++ --std=c++11 queue.cpp -o queue -lpthread

C++

#include <mutex>
#include <iostream>
#include <thread>
#include <queue>
#include <condition_variable>
 
template <typename Event>
struct ThreadSafeQueue {
public: /* methods: */
        Event /* Called by the consumer. */
        getEvent()
        {
                std::unique_lock<std::mutex> lock(mutex);
                while (events.empty()) {
                        condition_variable.wait(lock);
                }
                auto tmp = events.front();
                events.pop();
                return tmp;
        };
 
        void /* Used by the producer. */
        setEvent(Event event)
        {
                std::lock_guard<std::mutex> lock(mutex);
                events.push(event);
                condition_variable.notify_one();
        };
 
private: /* fields: */
        std::queue<Event> events;
        std::mutex mutex;
        std::condition_variable condition_variable;
};
 
struct Event {
        char c;
};
 
ThreadSafeQueue<Event> queue;
 
void
getChar()
{
        char tmp;
        while (std::cin >> tmp)
        {
                Event event {tmp};
                queue.setEvent(event);
        }
};
 
void
print()
{
        while (true)
        {
                std::cout << queue.getEvent().c << std::endl;
        }
};
 
int
main(int argc, char** argv)
{
        std::thread printer {print};
        printer.detach();
        getChar();
};

На пример, наипростейшая потокобезопастная очередь. Защищена мьютексом, который лочится в RAII стиле, то бишь создаётся переменная std::lock_guard<std::mutex> lock(mutex) она в конструкторе делает lock(), когда теряется область, в деструкторе вызывается unlock(). Вообще, всё это ооп-шный сахар. Помутузь posix threads, или виндапотоки, а всё вышеприведённое - ни что иное как обёртка над системными тредами. Можешь даже сам попробовать потом обернуть нативные потоки согласно плюснотому стандарту.

@MastAKK · 17.08.2014, 01:05 **[ТС]**

Andrej, проблема в том, что хотелось бы без блокировки потока. То бишь, запустить несколько отдельных потоков, работающих параллельно.
Или mutex позволяет одновременную работу нескольких потоков?

@Andrej · 17.08.2014, 01:17

MastAKK, да, позволяет. Идея этой штуки как раз в том, чтобы был один потребитель и N производителей событий.
Здесь только потребитель висит на ожидании.
std::thread::detach метод делает поток независимым. А вот std::thread::join ждёт окончания исполнения потока.

Убежденный · 17.08.2014, 10:21

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

Подскажите, как я могу изменить переменную в дочерних потоках так, чтобы она изменялась и в основном?

Для начала почитать про std::atomic/Boost.atomic.

http://ru.cppreference.com/w/cpp/atomic/atomic
http://www.boost.org/doc/libs/1_55_0/doc/html/atomic.html

@DrOffset 7514 / 4510 / 1024 Регистрация: 30.01.2014 Сообщений: 7,362
	17.08.2014, 00:41	#2
	Хабр конечно не самый лучший источник информации, но представление определенное получишь. В любом случае проще прочитать там, чем сейчас тут целую статью писать 1

@MastAKK 145 / 136 / 12 Регистрация: 13.10.2012 Сообщений: 592
	17.08.2014, 00:45 [ТС]	#3
	DrOffset, ну что же, действительно, придётся почитать хабр. Может и тонкости какие узнаю. Благодарб за ссылку 0

@MastAKK 145 / 136 / 12 Регистрация: 13.10.2012 Сообщений: 592
	17.08.2014, 01:05 [ТС]	#5
	Andrej, проблема в том, что хотелось бы без блокировки потока. То бишь, запустить несколько отдельных потоков, работающих параллельно. Или mutex позволяет одновременную работу нескольких потоков? 0

@Andrej И целого heap'а мало 94 / 55 / 9 Регистрация: 31.07.2014 Сообщений: 291
	17.08.2014, 01:17	#6
	MastAKK, да, позволяет. Идея этой штуки как раз в том, чтобы был один потребитель и N производителей событий. Здесь только потребитель висит на ожидании. std::thread::detach метод делает поток независимым. А вот std::thread::join ждёт окончания исполнения потока. 0

Убежденный Ушел с форума 15928 / 7238 / 1140 Регистрация: 02.05.2013 Сообщений: 11,637 Записей в блоге: 1 Завершенные тесты: 1
	17.08.2014, 10:21	#7
	Сообщение от MastAKK Подскажите, как я могу изменить переменную в дочерних потоках так, чтобы она изменялась и в основном? Для начала почитать про std::atomic/Boost.atomic. http://ru.cppreference.com/w/cpp/atomic/atomic http://www.boost.org/doc/libs/1_55_0/doc/html/atomic.html 0

Опции темы

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

Как работать с переменной в нескольких потоках? - C++