C ++: правильный способ обмена значениями (данными) между различными потоками - PullRequest
Новая
       29

C ++: правильный способ обмена значениями (данными) между различными потоками

0 голосов
/ 15 марта 2019

У меня есть следующий Thread.cpp: 

   while (1) 
    {
       rplidar_response_measurement_node_t nodes[8192];
       size_t   count = _countof(nodes);

       op_result = drv->grabScanData(nodes, count);

       if (IS_OK(op_result)) 
        {
           drv->ascendScanData(nodes, count);

           for (int pos = 0; pos < (int)count ; ++pos) 
            {

               nodes[pos].sync_quality & RPLIDAR_RESP_MEASUREMENT_SYNCBIT;
               nodes[pos].angle_q6_checkbit >> RPLIDAR_RESP_MEASUREMENT_ANGLE_SHIFT/64.0f;
               nodes[pos].distance_q2/4.0f;
               nodes[pos].sync_quality >> RPLIDAR_RESP_MEASUREMENT_QUALITY_SHIFT;
            }
        }
    }
  return ;
}

Motion Thread.cpp 

void Motion::Synchronization(QString motiontype)
{
      if(motiontype == START)
       {

   if(269<Thread::angle_q6_checkbit && Thread::angle_q6_checkbit <271)
    {
        if(Thread::distance_q2>1200)
        {
            dist_left=1200;
        }
     else
      {
           dist_left=Thread::distance_q2;
      }
                cout<<"Motion +Stuff+="<< endl;
    }
  }
}

Это не мой точный код, это та часть, где я получу данные и сохраню их в переменной. distance_q2, angle_q6_checkbit и т. Д. НЕ являются атомарной переменной, поэтому чтение и запись их из другого потока не согласованы !! В той же теме, если я попытался напечатать данные, я получаю правильное чтение. Вывод приведен ниже.

Proper data from Thread.cpp

Теперь я попытался взять данные для обработки или других моих вещей. Сохранение данных о расстоянии, качестве угла, например, Thread::sync_quality, Thread::angle_q6_checkbit, Thread::distance

Получение данных из лазерных данных Thread.cpp в motion.cpp нить (данные cout в потоке движения): 

cout << "distance "<< Thread::distance_q2 << endl;
cout << "angle "<< Thread::angle_q6_checkbit << endl;
cout << "quality level "<< int(Thread::sync_qualitylevel) << endl;

Я получаю неправильный вывод (получаю только 359 градусов, что тоже неправильно). Я не могу заключить. Теперь вывод для вышеупомянутого:

Improper data with another thread motion.coo

Я пытался объявить тогда как атомарный, но я не вижу никаких улучшений. Помощь будет принята с благодарностью.

...