我对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 Example和Broadcast Sender Example,并编写类似的代码。
至于超时问题,您可以将QTimer
的timeout()
信号连接到发送数据报的插槽,以便在指定时间内没有响应的情况下,它继续发送数据包,并发送计时器。在连接到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/