Таймер в потоке

[Andrew Vladoff]

В потоке обрабатываются определенные данные. Одной функцией потока данные добавляются в список, а по таймеру этот список очищается. Нужно ли использовать критические секции во время срабатывания таймера? Таймер запускается в этом же потоке или для него создается отдельный?

[BRE]

Ты бы показал, как у тебя это все происходит.
Если я правильно тебя понял, то можно сделать так, что бы синхронизацией занималась сама очередь сообщений потока.

[Andrew Vladoff]

Ты бы показал, как у тебя это все происходит.

Если в двух словах.
Есть поток

Код:

//---------------------------------------------------------------------------
void CThr::run(void)
{ 
  // Объявляем Таймер
   pTimer = new QTimer(this);
   connect(pTimer, SIGNAL(timeout()), this, SLOT(s_OnTimer()));
   pTimer->start(1000);

   //--------- чтение пакетов и заполнение списка
  while (!flStop)
   {
     ..Здесь получаем некоторые данные и копируем в список, например QVector
  
   }
}
//---------------------------------------------------------------------------
void CThr::s_OnTimer(void) 
{ 
  //..... Здесь по таймеру удаляем некоторые данные из QVector
  // Нужны ли здесь критические секции :
EnterCriticalSection (&Sect);
  ... удаление данных

LeaveCriticalSection (&Sect);



}

Вопрос для Таймера приложением создается и запускается отдельный поток или же запуск происходит в моем потоке CThr? И нужны ли критические секции (во время добавления данных в список и удаления по таймеру из списка)?

[BRE]

Вопрос для Таймера приложением создается и запускается отдельный поток или же запуск происходит в моем потоке CThr?

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

И нужны ли критические секции (во время добавления данных в список и удаления по таймеру из списка)?

Если будет запущена обработка событий, то никакие критические секции не нужны, потому что два этих действия (добавление и очистка) будут разнесены.

[Andrew Vladoff]

Если будет запущена обработка событий, то никакие критические секции не нужны, потому что два этих действия (добавление и очистка) будут разнесены

Т.е. код который я привет (если убрать критические секции) написан правильно, косяков не должно быть?

[BRE]

Т.е. код который я привет (если убрать критические секции) написан правильно, косяков не должно быть?

Не все здесь видно, набросаю свой код:

Код

C++ (Qt)
CThr::CThr() : ...
{
	moveToThread( this );
}
 
void CThr::run(void)
{ 
  // Объявляем Таймер
   QTimer timer;
   connect( &timer, SIGNAL(timeout()), SLOT(s_OnTimer()), Qt::DirectConnection );	// укажим принудительно прямое подключение
   timer.start(1000);
 
   QEventLoop loop;
 
   //--------- чтение пакетов и заполнение списка
  while (!flStop)
   {
     ..Здесь получаем некоторые данные и копируем в список, например QVector
     loop.processEvents();    // прокрутили очередь сообщений + таймеры
   }
}
 

[twp]

Код

C++ (Qt)
void CThr::run(void)
{ 
  // Объявляем Таймер
   QTimer timer;
   connect( &timer, SIGNAL(timeout()), SLOT(s_OnTimer()), Qt::DirectConnection );	// укажим принудительно прямое подключение
   timer.start(1000);
 
   QEventLoop loop;
 
   //--------- чтение пакетов и заполнение списка
  while (!flStop)
   {
     ..Здесь получаем некоторые данные и копируем в список, например QVector
     loop.processEvents();    // прокрутили очередь сообщений + таймеры
   }
}
 

имхо можно обойтись без QEventLoop, а обработку сообщений сделать через int QThread::exec() тогда просто:

Код

C++ (Qt)
void CThr::run(void)
{
   QTimer timer;
   connect( &timer, SIGNAL(timeout()), SLOT(s_OnTimer()), Qt::DirectConnection );
   timer.start(1000);
 
   exec();
}
 

[Igors]

Код

C++ (Qt)
  while (!flStop)
   {
     ..Здесь получаем некоторые данные и копируем в список, например QVector
     loop.processEvents();    // прокрутили очередь сообщений + таймеры
   }
}
 

В большинстве случаев вероятно потребуется флажок

Код

C++ (Qt)
loop.processEvents(QEventLoop::WaitForMoreEvents);
 

Иначе нитка будет крутиться вхолостую. Хотя конечно, перекрывать стандартный exec (неск строчек) или нет - дело вкуса

[bass667]

Здравствуйте. Использую такой же код, только вот проблема - функция по таймеру вызывается не в новом потоке, а в старом (основном). Почему так может быть?

[mutineer]

Здравствуйте. Использую такой же код, только вот проблема - функция по таймеру вызывается не в новом потоке, а в старом (основном). Почему так может быть?

Какой из приведенных версий кода ты пользуешься?

[bass667]

Все варианты попробовал.

Всё, разобрался.
Я всё перепутал, всё правильно, поток создаётся, всё запускается. Если соединять сигнал со слотом с параметром Qt::DirectConnection, то всё работает правильно. Без этого параметра (т.е. с параметром по умолчанию) при блокировке основного потока, во втором потоке функция по таймеру переставала вызываться.