Многопоточность, выход из бесконечного цикла c++11

@el_gato_de_Ch · Регистрация: 28.04.2013

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

Всем привет. Я в задачах многопоточности - новичок (начал ей заниматься буквально несколько часов назад), инфу искал, читал, но как-то пока не помогает.

Столкнулся с задачей (с++11 std::thread) код не оригинальный, а упрощённый, чтобы показать саму суть, подразумевается, что все необходимые include'ы уже есть.

есть

C++

class SomeClass
{
private:
   bool _stopCycle;
public:
  void inifiniteWhile()
  {
      _stopCycle = false;
 
      while(!_stopCycle)
      {
          // do things ...
          // show window
      }
  }
 
   void stop() {_stopCycle = false;}
 
};

Main function

C++

int main()
{
   SomeClass obj;
   thread someThread(&SomeClass::obj, infiniteCycle);
 
   while(/*read command from cmd*/)
   {
      if(cmd == exit)
      {
         obj.stop();
         break;
      }
   }
 
   system("pause");
}

Гарантируется, что из while(read cmd) программа выходит, т.е. я прихожу к system("pause");

Проблема: someThread не останавливает работу функции infinite. Цикл так и продолжает крутиться, выполняются do things и show window.
Вопрос: Как завершить цикл ?

alsav22 · 04.06.2014, 00:52

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

Как завершить цикл ?

Присвоить _stopCycle true.

Добавлено через 37 минут

C++

#include <iostream>
#include <thread>
#include <cstdlib>
using namespace std;
 
class SomeClass
{
    volatile bool _stopCycle;
public:
 
  void inifiniteWhile()
  {
      _stopCycle = false;
      while (!_stopCycle)
      {
          cout << "inifiniteWhile" << endl;
      }
  }
 
   void stop() {_stopCycle = true;}
 
};
 
int main()
{
   SomeClass obj;
   thread someThread(&SomeClass::inifiniteWhile, &obj);
   someThread.detach();
 
   chrono::milliseconds dura(10);
   this_thread::sleep_for(dura);
 
   while(true)
   {
      if(true)
      {
         obj.stop();
         break;
      }
   }
 
   system("pause");
}

C++

#include <iostream>
#include <thread>
#include <cstdlib>
using namespace std;
 
class SomeClass
{
public:
  volatile bool _stopCycle;
 
  SomeClass()
  {
      _stopCycle = true;
  }
 
  void inifiniteWhile()
  {
      _stopCycle = false;
 
      while(!_stopCycle)
      {
          cout << "inifiniteWhile ";
      }
  }
 
   void stop() {_stopCycle = true;}
 
};
 
int main()
{
   SomeClass obj;
   thread someThread(&SomeClass::inifiniteWhile, &obj);
   someThread.detach();
 
   while(true)
   {
      if(!obj._stopCycle)
      {
         obj.stop();
         break;
      }
   }
 
   system("pause");
}

@el_gato_de_Ch · 04.06.2014, 08:33 **[ТС]**

у меня ошибка в оригинальном посте

C++

void SomeClass::stop()
{
   _stopCycle = true;
}

и цикл всё равно крутится =(

alsav22 · 04.06.2014, 12:19

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

и цикл всё равно крутится =(

Я показал, как можно сделать, чтобы не крутился.

Добавлено через 2 минуты
У вас крутится потому, что obj.stop() (в главном потоке) происходит раньше, чем _stopCycle = false во втором потоке.

@el_gato_de_Ch · 04.06.2014, 12:26 **[ТС]**

alsav22, я сильно сомневаюсь в том что obj.stop() происходит раньше старта, к сожалению, сейчас исходников нет, я проверить не смогу, но я полагаю что работает это так:

1. у меня происходит запуск потока с циклом
2. Основной поток в этот момент начинает считывать команды с консоли
3. stop() вызывается только, когда в консоль придёт соответствующая команда (цикл уже стартовал) ...

читая описание, я не совсем понял как работает detach(), если не трудно объясните попроще,

join() как я понимаю блокирует вызывающий поток до завершения функции,
detach() отсоединяет вызванный поток от вызывающего, правильно ?

alsav22 · 04.06.2014, 12:38

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

но я полагаю что работает это так:

Полагать можно всё что угодно. Работа вашего кода показывает, что ваши предположения неверны. Сделайте паузу в остновном потоке (как у меня в первом коде), чтобы второй поток успел дойти до _stopCycle = false, тогда можно уже будет рассуждать.

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

читая описание, я не совсем понял как работает detach(), если не трудно объясните попроще,

Это к вопросу о зацикливании отношения не имеет, читайте документацию.

Добавлено через 2 минуты
Вот этот кусок нормальный выложите, чтобы можно было проверить работу:

C++

while(/*read command from cmd*/)
   {
      if(cmd == exit)
      {
         obj.stop();
         break;
      }
   }

@Somebody · 04.06.2014, 12:40

Думаю, так как _stopCycle в цикле нигде не изменяется, условие в while оптимизиуется до true. Надо заменить bool на std::atomic<bool> (а не volatile bool, кстати).

alsav22 · 04.06.2014, 12:57

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

а не volatile bool, кстати

volatile чем не устраивает?
В первом моём коде (где пауза делается в основном потоке) зацикливания нет (даже без volatile), если убрать паузу, то есть. Вывод?

Добавлено через 1 минуту

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

у меня ошибка в оригинальном посте

И не одна.

Добавлено через 7 минут

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

Вывод?

Но это всё рассуждения относительно моего кода. У ТС может и другая быть причина (связанная с оптимизацией или с чем другим), но проверить нет возможности из-за непонятного куска кода.

@taras atavin · 04.06.2014, 13:01

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

у меня ошибка в оригинальном посте

C++

void SomeClass::stop()
{
 _stopCycle = true;
}

и цикл всё равно крутится =(

А ты её вызываешь?

@el_gato_de_Ch · 04.06.2014, 13:06 **[ТС]**

taras atavin, да

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

if(cmd == exit)
* * * {
* * * * *obj.stop();
* * * * *break;
* * * }

@Somebody · 04.06.2014, 13:07

Такое использование volatile не соответствует стандарту.
http://alenacpp.blogspot.ru/2006/04/volatile.html
(И на форуме уже где-то об этом писалось.)
Сейчас уже и M$ это не рекомендует.

alsav22 · 04.06.2014, 13:15

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

да

А заход в while(), где этот if?

Не по теме:

Добавлено через 3 минуты

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

Такое использование volatile не соответствует стандарту.

Не будем отвлекаться и спорить на другую тему (я вообще потоки С++11 не использую (использую Qt)).

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

Сейчас уже и M$ это не рекомендует.

Какое отношение M$ имеет к стандарту? Пусть дальше рекомендует...

Добавлено через 3 минуты
...

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

В первом моём коде (где пауза делается в основном потоке) зацикливания нет (даже без volatile), если убрать паузу, то есть. Вывод?

@taras atavin · 04.06.2014, 13:20

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

alsav22 · 04.06.2014, 13:23

Сообщение от taras atavin

Может в этом дело?

Я думаю, что в этом:

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

У вас крутится потому, что obj.stop() (в главном потоке) происходит раньше, чем _stopCycle = false во втором потоке.

Если, конечно, есть заход в while() в главном потоке (иначе obj.stop() вообще не происходит).

@Somebody · 04.06.2014, 13:24

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

В первом моём коде (где пауза делается в основном потоке) зацикливания нет (даже без volatile), если убрать паузу, то есть. Вывод?

Вывод: правильность кода не является необходимым условием для правильности его работы, не более того.

alsav22 · 04.06.2014, 13:32

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

Вывод: правильность кода не является необходимым условием для правильности его работы, не более того.

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

@taras atavin · 04.06.2014, 13:46

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

правильность кода не является необходимым условием для правильности его работы, не более того.

То есть чётная ошибка ошибкой не является?

@Somebody · 04.06.2014, 14:00

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

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

В каком коде? Зацикливания в основном потоке не вижу нигде...

alsav22 · 04.06.2014, 16:01

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

В каком коде?

В моём, первом (если убрать паузу в основном потоке).

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

Зацикливания в основном потоке не вижу нигде...

Об этом и речь нигде не идёт...

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

не останавливает работу функции infinite. Цикл так и продолжает крутиться, выполняются do things и show window.

Во втором потоке.

Добавлено через 1 час 12 минут
el_gato_de_Ch, попробуйте, в своём коде, вот так сделать:

C++

   while(/*read command from cmd*/)
   {
      if(cmd == exit)
      {
         cout << "if()" << endl;
         system("pause");
         obj.stop();
         break;
      }
   }

Когда произойдёт зацикливание во втором потоке, нажмите на любую клавишу.

@Somebody · 04.06.2014, 18:38

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

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

Действительно, obj.stop() может выполниться раньше, чем _stopCycle = false. При первом запуске у меня этого не произошло, и я не обратил внимания. Но зацикливается не всегда, а как повезёт (у меня, например, с включенным антивирусом зацикливается реже, чем с выключенным). (Однако всего предыдущего про оптимизацию условия и volatile это не отменяет.)

@taras atavin 4226 / 1795 / 211 Регистрация: 24.11.2009 Сообщений: 27,562
	04.06.2014, 13:46	17
	Сообщение от Somebody правильность кода не является необходимым условием для правильности его работы, не более того. То есть чётная ошибка ошибкой не является? 0

alsav22 5498 / 4893 / 831 Регистрация: 04.06.2011 Сообщений: 13,587
	04.06.2014, 12:19	4
	Сообщение от el_gato_de_Ch и цикл всё равно крутится =( Я показал, как можно сделать, чтобы не крутился. Добавлено через 2 минуты У вас крутится потому, что obj.stop() (в главном потоке) происходит раньше, чем _stopCycle = false во втором потоке. 0

@el_gato_de_Ch 36 / 36 / 2 Регистрация: 28.04.2013 Сообщений: 110
	04.06.2014, 12:26 [ТС]	5
	alsav22, я сильно сомневаюсь в том что obj.stop() происходит раньше старта, к сожалению, сейчас исходников нет, я проверить не смогу, но я полагаю что работает это так: 1. у меня происходит запуск потока с циклом 2. Основной поток в этот момент начинает считывать команды с консоли 3. stop() вызывается только, когда в консоль придёт соответствующая команда (цикл уже стартовал) ... читая описание, я не совсем понял как работает detach(), если не трудно объясните попроще, join() как я понимаю блокирует вызывающий поток до завершения функции, detach() отсоединяет вызванный поток от вызывающего, правильно ? 0

@Somebody 2835 / 1644 / 254 Регистрация: 03.12.2007 Сообщений: 4,222
	04.06.2014, 12:40	7
	Думаю, так как _stopCycle в цикле нигде не изменяется, условие в while оптимизиуется до true. Надо заменить bool на std::atomic<bool> (а не volatile bool, кстати). 0

alsav22 5498 / 4893 / 831 Регистрация: 04.06.2011 Сообщений: 13,587
	04.06.2014, 12:57	8
	Сообщение от Somebody а не volatile bool, кстати volatile чем не устраивает? В первом моём коде (где пауза делается в основном потоке) зацикливания нет (даже без volatile), если убрать паузу, то есть. Вывод? Добавлено через 1 минуту Сообщение от el_gato_de_Ch у меня ошибка в оригинальном посте И не одна. Добавлено через 7 минут Сообщение от alsav22 Вывод? Но это всё рассуждения относительно моего кода. У ТС может и другая быть причина (связанная с оптимизацией или с чем другим), но проверить нет возможности из-за непонятного куска кода. 0

@el_gato_de_Ch 36 / 36 / 2 Регистрация: 28.04.2013 Сообщений: 110
	04.06.2014, 13:06 [ТС]	10
	taras atavin, да Сообщение от el_gato_de_Ch if(cmd == exit) * * * { * * * * obj.stop(); * * * break; * * } 0

@Somebody 2835 / 1644 / 254 Регистрация: 03.12.2007 Сообщений: 4,222
	04.06.2014, 13:07	11
	Такое использование volatile не соответствует стандарту. http://alenacpp.blogspot.ru/2006/04/volatile.html (И на форуме уже где-то об этом писалось.) Сейчас уже и M$ это не рекомендует. 0

alsav22 5498 / 4893 / 831 Регистрация: 04.06.2011 Сообщений: 13,587
	04.06.2014, 13:15	12
	Сообщение от el_gato_de_Ch да А заход в while(), где этот if? Не по теме: Добавлено через 3 минуты Сообщение от Somebody Такое использование volatile не соответствует стандарту. Не будем отвлекаться и спорить на другую тему (я вообще потоки С++11 не использую (использую Qt)). Сообщение от Somebody Сейчас уже и M$ это не рекомендует. Какое отношение M$ имеет к стандарту? Пусть дальше рекомендует... Добавлено через 3 минуты ... Сообщение от alsav22 В первом моём коде (где пауза делается в основном потоке) зацикливания нет (даже без volatile), если убрать паузу, то есть. Вывод? 0

@taras atavin 4226 / 1795 / 211 Регистрация: 24.11.2009 Сообщений: 27,562
	04.06.2014, 13:20	13
	Была у меня как то проблема межпоточного взаимодействия, выглядело поведение проги так, как если бы два потока работали с отдельными копиями переменных. Может в этом дело? 0

alsav22 5498 / 4893 / 831 Регистрация: 04.06.2011 Сообщений: 13,587
	04.06.2014, 13:23	14
	Сообщение от taras atavin Может в этом дело? Я думаю, что в этом: Сообщение от alsav22 У вас крутится потому, что obj.stop() (в главном потоке) происходит раньше, чем _stopCycle = false во втором потоке. Если, конечно, есть заход в while() в главном потоке (иначе obj.stop() вообще не происходит). 0

@Somebody 2835 / 1644 / 254 Регистрация: 03.12.2007 Сообщений: 4,222
	04.06.2014, 13:24	15
	Сообщение от alsav22 В первом моём коде (где пауза делается в основном потоке) зацикливания нет (даже без volatile), если убрать паузу, то есть. Вывод? Вывод: правильность кода не является необходимым условием для правильности его работы, не более того. 0

alsav22 5498 / 4893 / 831 Регистрация: 04.06.2011 Сообщений: 13,587
	04.06.2014, 13:32	16
	Сообщение от Somebody Вывод: правильность кода не является необходимым условием для правильности его работы, не более того. Что можете сказать о зацикливании без паузы в основном потоке? Почему происходит? 0

@Somebody 2835 / 1644 / 254 Регистрация: 03.12.2007 Сообщений: 4,222
	04.06.2014, 14:00	18
	Сообщение от alsav22 Что можете сказать о зацикливании без паузы в основном потоке? Почему происходит? В каком коде? Зацикливания в основном потоке не вижу нигде... 0

@Somebody 2835 / 1644 / 254 Регистрация: 03.12.2007 Сообщений: 4,222
	04.06.2014, 18:38	20
	Сообщение от alsav22 Что можете сказать о зацикливании без паузы в основном потоке? Почему происходит? Действительно, obj.stop() может выполниться раньше, чем _stopCycle = false. При первом запуске у меня этого не произошло, и я не обратил внимания. Но зацикливается не всегда, а как повезёт (у меня, например, с включенным антивирусом зацикливается реже, чем с выключенным). (Однако всего предыдущего про оптимизацию условия и volatile это не отменяет.) 0