我对QThread还是很陌生,我想用Qt制作一个多线程应用程序。有很多在线资源,有人建议将QThread子类化,有人说这是不正确的,他们使用moveToThread函数。我真的很困惑。也许这取决于需求,所以我正在写我的需求。

该软件将通过UDP协议与设备通信。设备将收到的数据包作为ACK发送回发送方。由于UDP不可靠,因此我想通过检查设备的答案来增加通信的可靠性。我想给设备一点时间来发送答案,如果没有答案(ACK数据包),我想再次发送相同的数据包。如果出现错误的答案数据包(不按顺序排列的数据包),我可以忽略它,而无需对其重新排序。将有一些数据包(设备命令)会定期发送,例如每秒发送一次。

我想使用QThread在线程中进行所有通信。单击一个按钮即可启动线程,并开始通信(某些数据包将定期发送)。单击按钮将停止通信。

那我该怎么办呢?我只需要步骤。

编辑:

我已经阻止了读写操作。我正在使用moveToThread函数将其移动到Thread并启动线程。但是我不知道这是否是用例的最佳方法。

例如,我一个接一个地发送一些数据报,例如:

int UDP::readCalibration(..)
{
    while(readStatus() != 0);

    // Send addr, read page command and read buffer command
    // one after each
    writeRegisterBlock(LOW_ADDR, CalibAddr, 2); // Blocking
    writeRegister(CMD_Reg, READ_PAGE);          // Blocking
    readRegisterBlock(READ_BUF, data, 128);     // Blocking
}
....
int UDP::writeRegisterBlock(...)
{
   ....// Build UdpPacket
   return UDP_Send(UdpPacket, &ReceivePacket);
}
int UDP::writeRegister(...)
{
   ....// Build UdpPacket
   return UDP_Send(UdpPacket, &ReceivePacket);
}
int UDP::readRegisterBlock(...)
{
   ....// Build UdpPacket
   return UDP_Send(UdpPacket, &ReceivePacket);
}
// and UDP_Send function, this is the important part
int UDP::UDP_Send(QByteArray UdpPacket, QByteArray *ReceivePacket)
{
    QByteArray Datagram;
    QHostAddress SenderAddress;
    quint16 SenderPort;
    int UDP_RetVal = -1, timeOutCounter = -1, NrOfSend = -1, NrOfRecv = -1, retVal = -1;
   bool pendingDatagram = false;

   SetContinueToRecv(true); // sets a boolean variable with mutex
   SetContinueToSend(true); // sets a boolean variable with mutex

   while ((NrOfSend < MAX_RETRY) && GetContinueToSend())
   {
       NrOfSend++;
       SetContinueToRecv(true); // start receiver loop
       UDP_RetVal = udpSocket->writeDatagram(UdpPacket, DestinationIP, port);

       if(UDP_RetVal < 0)
       {
           qDebug() << "udpSocket error";
       }
       else
       {
           while((NrOfRecv <  MAX_RETRY) && GetContinueToRecv())
           {
               pendingDatagram = false;

               while (!pendingDatagram && (timeOutCounter < TIMEOUT_MS))
               {
                   msleep(SLEEP_MS);
                   timeOutCounter++;
                   pendingDatagram = udpSocket->hasPendingDatagrams();
               }

               if (timeOutCounter < TIMEOUT_MS)
               {
                   Datagram.resize(udpSocket->pendingDatagramSize());
                   udpSocket->readDatagram(Datagram.data(), Datagram.size(), &SenderAddress, &SenderPort);

                   //Compare only first 4 bytes, cmd, nr, addr
                   if((UdpPacket.mid(0, 4) == Datagram.mid(0, 4)) && (SenderAddress == DestinationIP) )
                   {
                       retVal = 0;
                       //Take only data , not commands
                       ReceivePacket->resize(Datagram.size()-4);
                       ReceivePacket->replace(0, Datagram.size()-4, Datagram.right(Datagram.size()-4));
                       SetContinueToRecv(false); // Break receiver while loop
                       SetContinueToSend(false); // Break sender while loop
                   }
                   else // Wrong packet
                   {
                       SetContinueToRecv(true); // try again to receive
                       timeOutCounter = -1;
                       qDebug() << "Wrong Packet.";
                   }    // Wrong packet
               }
               else // Timeout
               {
                   qDebug() << "Timeout maximum. NrOfSend: " << NrOfSend << " NrOfRecv: " << NrOfRecv;
                   timeOutCounter = -1;
                   SetContinueToSend(true); // try again to send
                   SetContinueToRecv(false);
               }   // Timeout
           }  // Receive loop
           NrOfRecv = -1;
       }  // Succesfully sent
   }  // Send loop
   if(NrOfSend == MAX_RETRY)
   {
      retVal = -1; // Could not send.
      qDebug() << "Could not send";
   }
   return retVal;
}


如何用readyRead和Timeout函数替换阻止函数?也许我必须保存发送的数据报,并且在超时时必须比较接收的数据报和发送的数据报,如果相同,则正确发送和接收数据包。如果没有,我必须再次发送吗?

最佳答案

我强烈建议您使用QUdpSocket类为您的用例提供的异步API。

使用连接到readyRead()信号的插槽,并在该插槽中使用readDatagram()实际从套接字读取接收到的数据。为了发送数据,请在任意位置使用writeDatagram(),它不会阻塞调用线程。

您可以阅读Broadcast Receiver ExampleBroadcast Sender Example,并编写类似的代码。

至于超时问题,您可以将QTimertimeout()信号连接到发送数据报的插槽,以便在指定时间内没有响应的情况下,它继续发送数据包,并发送计时器。在连接到start()信号的插槽中调用的readyRead()方法(以便在每次接收到数据报时计时器重新启动)。

为了回答有关多线程的问题,一种简短的使用方法是拥有一个从QObject派生的类,并实现需要在该类中执行的插槽,然后实例化一个新的QThread并调用该对象上的moveToThread()到新的QThread。之后,当连接到该对象插槽的任何信号发出时,插槽代码将在新线程中执行。

但是,值得注意的是,在Qt中有多种利用多线程的方法,每个用例都有实现它的方法,请在此处Multithreading Technologies in Qt看看。并且在您的用例中,根本不要使用多线程。

编辑:
因此您无法上网,并且实施了阻止读写操作。 。 。


  我正在使用moveToThread函数将其移动到线程并启动线程


首先,必须确保将QObject移到新线程后,不要调用直接使用阻塞IO的函数,而是通过将信号连接到它并发出该信号来调用它,或使用QMetaObject::invokeMethod。因为直接调用它会在调用者的线程(最有可能是GUI线程)中执行您的功能,所以我们不想这样做。 。 。

我可以看到您正在msleep中呼叫UDP::UDP_Send。请不要告诉我您的UDP类是从QThread继承的,请再次阅读我的答案以了解您应该从中继承什么。

似乎您正在通过每个QUdpSocket调用hasPendingDatagrams来轮询SLEEP_MS。如果要继续使用阻塞模式,请改用waitForReadyRead,这样线程将一直阻塞,直到QUdpSocket接收到数据报为止。 。 。

这些迹象表明您没有使代码在新的线程权利中执行。 。 。

附言:使用我初次告诉您的异步方式重新编写代码,比修复当前代码要容易,简单和整洁。只是阅读我链接的示例,如果您不了解某些内容,可以随时询问。 。 。

关于c++ - 需要有关使用QThread的多线程应用程序的帮助,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/35340933/

10-14 18:20
查看更多