А вот такой вопрос - для блокировки потока используется std::unique_lock, но, как я понял он создается именно в функции, которую нужно блокировать. И тут, как бы не совсем понятно, вот к примеру создал поток, сразу усыпил его, потом разбудил, поток выполнил работу, НО функцию не завершается, функция зациклена, и после выполнения одного цикла идет второй, но на втором круге цикла опять встречается строка:
std::unique_lock<std::mutex> my_lock(my_mutex);
И получается, что std::unique_lock - создается постоянно в цикле ? Я имею ввиду не цикл while, а "цикл" goto. Когда код возвращается к метке repeat: и к строке std::unique_lock - получается опять создается новый объект std::unique_lock ?
Вот пример кода:
#include <iostream> // std::cout
#include <thread> // std::thread
#include <mutex> // std::mutex, std::unique_lock
#include <condition_variable> // std::condition_variable
#include <vector>
std::mutex my_mutex;
std::condition_variable my_cond_var;
int global_status;
void waiting_threads(int id)
{
repeat:
//----------------------------------------------------------------
{
std::unique_lock<std::mutex> my_lock(my_mutex); //Получается он постоянно создается в цикле ?
while (global_status == 0)
{
my_cond_var.wait(my_lock);
}
}
//----------------------------------------------------------------
std::cout << "thread_id:" << std::this_thread::get_id() << ":" << id << std::endl;
std::this_thread::sleep_for(std::chrono::seconds(1)); //Какая то работа потока.
goto repeat;
}
void go_1()
{
global_status = 1;
my_cond_var.notify_one();
}
void go_2()
{
global_status = 0;
}
void go_3()
{
global_status = 1;
my_cond_var.notify_one();
}
int main()
{
global_status=0;
int kol_vo_thread = 4; //Условное кол-во ядер.
std::vector<std::thread> my_thread_vec;
my_thread_vec.resize(kol_vo_thread);
//-----------------------------------------------------
for (int i = 0; i < kol_vo_thread; i++)
{
my_thread_vec[i] = std::thread(waiting_threads, i);
}
//-----------------------------------------------------
std::this_thread::sleep_for(std::chrono::seconds(1));
go_1(); //Пробуждаем поток.
std::this_thread::sleep_for(std::chrono::milliseconds(10));
go_2(); //Потом усыпляем его.
std::this_thread::sleep_for(std::chrono::seconds(1));
go_3(); //И опять, когда нужно пробуждаем.
//------------------------------------------------
for (int i = 0; i < kol_vo_thread; i++)
{
my_thread_vec[i].join();
}
//------------------------------------------------
}
my_lock
автоматически уничтожается (с освобождениемmy_mutex
) при выходе из {...} (он объявлен внутри блока из фигурных скобок). Да, послеgoto repeat
он будет снова создан.