Как синхронизировать между собой два потока

@Igor7117 · Регистрация: 25.08.2014

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

Привет, народ.
Есть вопросик по потокам. Callback функция постоянно дёргает решатель в отдельном потоке. В примере это цикл в функции main. Решение заменено слипами, а так идею я попытался передать. Если решатель не отработал до конца, то его надо остановить и запустить заново. Придумал я такой вот код для примера. Он рабочий и его можно скомпилить. Вопрос такой: правильно ли я в этом случае пользуюсь мьютексами?

C++ (Qt)
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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
// thread.cpp : Defines the entry point for the console application.
//
 
#include "stdafx.h"
 
#include <thread>
#include <iostream>
#include <conio.h>
 
#include <iostream>
#include <chrono>
#include <thread>
#include <mutex>
 
struct MyThreadStatus
{
    int threadStatus;
    int threadTodo;
};
 
std::mutex g_lock;
MyThreadStatus myThreadStatus;
 
 
 
void threadFunction(int *res, MyThreadStatus *pThread)
{
    while (true)
    {
        if (pThread->threadTodo == 1)
        {
            g_lock.lock();
            pThread->threadStatus = 1;
            g_lock.unlock();
        }
 
        if (pThread->threadStatus == 0)
            continue;
 
        for (int i = 0; i < 10000000; i++)
        {
            if (pThread->threadTodo == 0)
            {
                g_lock.lock();
                pThread->threadStatus = 0;
                g_lock.unlock();
                break;
            }
 
            ++(*res);
 
            std::this_thread::sleep_for(std::chrono::seconds(1));
        }
 
        pThread->threadStatus = 0;
 
    }
}
 
int main()
{
    int t(0);
    srand((unsigned int)time(0));
    std::thread *t1(NULL);
    bool newData(false);
 
 
    myThreadStatus.threadStatus = 0;
    myThreadStatus.threadTodo = 0;
 
    int result = 0;
 
    std::thread myThread(threadFunction, &result, &myThreadStatus);
    myThread.detach();
 
    for (int i = 0; i < 10; ++i) // Тут аналог вызова CallBack
    {
        
        if (myThreadStatus.threadStatus != 0) // проверяем, идёт ли счёт в потоке
        {
            myThreadStatus.threadTodo = 0; // устанавливаем флаг остановки счёта в потоке
            while (myThreadStatus.threadStatus != 0); // ждём пока поток остановится
        }
 
        std::this_thread::sleep_for(std::chrono::seconds(5)); // ждём 5 секунд 
        std::cout << "Result = " << result << std::endl;
 
        myThreadStatus.threadTodo = 1; // Запускаем счёт заново
 
        std::this_thread::sleep_for(std::chrono::seconds(5)); // ждём 5 секунд 
 
    }
 
    _getch();
    return 0;
}

Заранее спасибо!

@schdub · 11.08.2015, 23:57

Igor7117, неправильно. Вы шарите myThreadStatus между двумя тредами, но g_lock используете только в одном, а доступ к ней в main происходит в обход мьютекса.

Раз уж используете std::mutex, std::thread то поглядите в сторону std::condition_variable - скорее всего вы что-то похожее пытаетесь изобрести.

Ilot · 12.08.2015, 07:30

1) Не правильное использование мюьтекса:

C++
1
2
3
4
5
6
        if (pThread->threadTodo == 1)
        {
            g_lock.lock();
            pThread->threadStatus = 1;
            g_lock.unlock();
        }

Вместо явных вызовов захвата/освобождения следует использовать стража:

C++
1
2
3
4
5
        if (pThread->threadTodo == 1)
        {
            std::lock_guard<std::mutex> lk(g_lock);
            pThread->threadStatus = 1;
        }

2)Запрещено обращаться к неатомарной переменной в разных потоках без защиты мьютексом. Это касается почти всех обращений к myThreadStatus в вашей программе.
В остальном присоеденяюсь к предыдущему оратору юзайте std::condition_variable

@Igor7117 · 12.08.2015, 07:30 **[ТС]**

Спасибо, на самом деле вместо std::mutex используется boost::mutex и boost::thread. В boost condition_variable тоже есть, я посмотрел. Спасибо, это то что надо как раз)

Всё же стало принципиально интересно. А если в лоб делать, то надо лочить любое изменение и проверку myThreadStatus?

Тогда main будет:

C++ (Qt)
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
int main()
{
    int t(0);
    srand((unsigned int)time(0));
    std::thread *t1(NULL);
    bool newData(false);
 
 
    myThreadStatus.threadStatus = 0;
    myThreadStatus.threadTodo = 0;
 
    int result = 0;
 
    std::thread myThread(threadFunction, &result, &myThreadStatus);
    myThread.detach();
 
    for (int i = 0; i < 10; ++i) // Тут аналог вызова CallBack
    {
        if (myThreadStatus.threadStatus != 0) // проверяем, идёт ли счёт в потоке
        {
            myThreadStatus.threadTodo = 0; // устанавливаем флаг остановки счёта в потоке
            while (myThreadStatus.threadStatus != 0); // ждём пока поток остановится
        }
 
        std::this_thread::sleep_for(std::chrono::seconds(5)); // ждём 5 секунд 
        std::cout << "Result = " << result << std::endl;
 
        myThreadStatus.threadTodo = 1; // Запускаем счёт
 
        g_lock.lock();
        std::this_thread::sleep_for(std::chrono::seconds(5)); // ждём 5 секунд 
        g_lock.unlock();
 
    }
 
    _getch();
    return 0;
}

Но как лочить тут?

C++ (Qt)
1
2
3
4
5
if (myThreadStatus.threadStatus != 0) // проверяем, идёт ли счёт в потоке
        {
            myThreadStatus.threadTodo = 0; // устанавливаем флаг остановки счёта в потоке
            while (myThreadStatus.threadStatus != 0); // ждём пока поток остановится
        }

Спасибо

Ilot · 12.08.2015, 07:34

Не по теме:

C++
1
2
3
g_lock.lock();
std::this_thread::sleep_for(std::chrono::seconds(5)); // ждём 5 секунд 
g_lock.unlock();

=-O

@Igor7117 · 12.08.2015, 11:53 **[ТС]**

Сорри,

C++ (Qt)
1
2
3
4
5
        g_lock.lock();
        myThreadStatus.threadTodo = 1; // Запускаем счёт
        g_lock.unlock();
 
        std::this_thread::sleep_for(std::chrono::seconds(5)); // ждём 5 секунд

Вот так) Но уже стало более-менее понятно

@hoggy · 12.08.2015, 12:08

Igor7117,

замените:

C++
1
2
3
4
5
struct MyThreadStatus
{
    int threadStatus;
    int threadTodo;
};

на

C++
1
2
3
4
5
struct MyThreadStatus
{
    std::atomic<int> threadStatus;
    std::atomic<int> threadTodo;
};

и можно использовать без всяких мутексов.

@Igor7117 · 12.08.2015, 22:26 **[ТС]**

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

lss · 12.08.2015, 23:52

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

использовал condition_variable.

Интересно, как? Как mutex-ы, в коде из первого поста? Всё в одном потоке?

@Igor7117 · 13.08.2015, 17:19 **[ТС]**

Ну нет конечно,не в одном, посмотрел хелпы boost::condition_variable. Там всё доходчиво описано)

C++ (Qt)
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
boost::condition_variable cond;
boost::mutex mut;
bool data_ready;
 
void process_data();
 
void wait_for_data_to_process()
{
    boost::unique_lock<boost::mutex> lock(mut);
    while(!data_ready)
    {
        cond.wait(lock);
    }
    process_data();
}
 
/////////////////////
 
void retrieve_data();
void prepare_data();
 
void prepare_data_for_processing()
{
    retrieve_data();
    prepare_data();
    {
        boost::lock_guard<boost::mutex> lock(mut);
        data_ready=true;
    }
    cond.notify_one();
}

Добавлено через 12 минут
И ещё вопросик. Инициализация происходит например так:

boost::thread myThread(threadFunction, &result, &myThreadStatus);

Код потока будет находиться в отдельной dll, т.к. это решатель, а задачи могут быть разные, соответственно и решатели тоже. Соответственно гдобальную переменную создать не получится. Могу ли я при инициализации передать ссылки на boost::condition_variable и boost::mutex вот так:

C++ (Qt)
1
2
boost::mutex mut;
boost::thread myThread(threadFunction, &result, &myThreadStatus, &mut);

Новые блоги и статьи Все статьи Все блоги /
SDL3 для Web (WebAssembly): Обработчик клика мыши в браузере ПК и касания экрана в браузере на мобильном устройстве 8Observer8 02.02.2026 Содержание блога Для начала пошагово создадим рабочий пример для подготовки к экспериментам в браузере ПК и в браузере мобильного устройства. Потом напишем обработчик клика мыши и обработчик. . .	Философия технологии iceja 01.02.2026 На мой взгляд у человека в технических проектах остается роль генерального директора. Все остальное нейронки делают уже лучше человека. Они не могут нести предпринимательские риски, не могут. . .	SDL3 для Web (WebAssembly): Вывод текста со шрифтом TTF с помощью SDL3_ttf 8Observer8 01.02.2026 Содержание блога В этой пошаговой инструкции создадим с нуля веб-приложение, которое выводит текст в окне браузера. Запустим на Android на локальном сервере. Загрузим Release на бесплатный. . .	SDL3 для Web (WebAssembly): Сборка C/C++ проекта из консоли 8Observer8 30.01.2026 Содержание блога Если вы откроете примеры для начинающих на официальном репозитории SDL3 в папке: examples, то вы увидите, что все примеры используют следующие четыре обязательные функции, а. . .
SDL3 для Web (WebAssembly): Установка Emscripten SDK (emsdk) и CMake для сборки C и C++ приложений в Wasm 8Observer8 30.01.2026 Содержание блога Для того чтобы скачать Emscripten SDK (emsdk) необходимо сначало скачать и уставить Git: Install for Windows. Следуйте стандартной процедуре установки Git через установщик. . . .	SDL3 для Android: Подключение Box2D v3, физика и отрисовка коллайдеров 8Observer8 29.01.2026 Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами. Версия v3 была полностью переписана на Си, в. . .	Инструменты COM: Сохранение данный из VARIANT в файл и загрузка из файла в VARIANT bedvit 28.01.2026 Сохранение базовых типов COM и массивов (одномерных или двухмерных) любой вложенности (деревья) в файл, с возможностью выбора алгоритмов сжатия и шифрования. Часть библиотеки BedvitCOM Использованы. . .	SDL3 для Android: Загрузка PNG с альфа-каналом с помощью SDL_LoadPNG (без SDL3_image) 8Observer8 28.01.2026 Содержание блога SDL3 имеет собственные средства для загрузки и отображения PNG-файлов с альфа-каналом и базовой работы с ними. В этой инструкции используется функция SDL_LoadPNG(), которая. . .

@schdub 3073 / 1411 / 425 Регистрация: 19.01.2009 Сообщений: 3,894
	11.08.2015, 23:57
	Igor7117, неправильно. Вы шарите myThreadStatus между двумя тредами, но g_lock используете только в одном, а доступ к ней в main происходит в обход мьютекса. Раз уж используете std::mutex, std::thread то поглядите в сторону std::condition_variable - скорее всего вы что-то похожее пытаетесь изобрести. 0

@Igor7117 0 / 0 / 1 Регистрация: 25.08.2014 Сообщений: 91
	12.08.2015, 22:26 [ТС]
	Спасибо, использовал condition_variable. Проблем нет. Сейчас попробую atomic. Посмотрю что с производительностью, т.к. система высоко нагружена 0