0

环境简介:我有一台设备运行一个用 qt 编写的应用程序。它有一个处理数据库操作(SQlite)的主线程和一个用于网络操作(通过3G)的单独线程。主线程事件循环由 QCoreApplication::exec 运行,另一个处理网络操作的线程由 QThread::exec 运行。顺便说一句,套接字线程关联在它启动后会发生变化(例如 moveToThread(socketThreadPtr))

问题简介:主线程忙于一个循环,以便从数据库中选择大约 10k 条记录,该循环大约需要 +30 秒。在网络线程中有一个 15 秒的计时器,它必须在每次到期时发送一条保持活动消息。问题是 timeout() 信号的插槽仅在循环完成后才执行。

到目前为止建立的解决方案(但不令人满意):如果我在选择记录的循环中调用 QCoreApplication::processEvents,问题就解决了,但我想知道是否存在解决方案而不是这种解决方法。

备注:定时器、信号和槽,提供发送保持活动消息的命令当前在主线程中处理(但读/写发生在网络线程中)。另外,我在网络线程上移动了计时器,但得到的结果与在主线程上的结果相同。

4

2 回答 2

1

你必须在你的网络线程中创建计时器,也许 Qtimer 是网络线程的成员,所以网络线程将在主线程中构造,并且其子线程的线程亲和性设置为主线程,接下来你将网络线程移动到新的 Qthread,但是Qtimer呢?它仍然存在于主线程中(除非您将网络类明确定义为它的父级,因此正如您所说 moveToThread 会影响对象的子级以及 Qtimer)

Qtimer 应该在网络线程中构建,您可以在其中一个网络线程槽中构建一个新的 Qtimer 并将其连接到 Qthread::start 信号。因此,通过调用 Qthrad 的 start 方法,您的插槽将在新线程上执行,并且 Qtimer 将分别在该线程上构造。

于 2016-12-16T10:44:05.897 回答
0

像这样的东西实际上应该在您的专用线程中创建套接字和计时器,因为您的主线程是服务器并且客户端应该在线程中处理。否则,只需在您的初始化函数中使用QTcpSocket::connectToHost()或。QTcpServer:::bind()

主线程:

auto t = new QThread();
t->start();
auto o = new MyThreadObject();
o.moveToThread(t);
o.setDescriptor(socketDesc);
QMetaObject::invokeMethod(o, "initialize", Qt::QueuedConnection);

我的线程对象:

class MyThreadObject : public QObject
{
  Q_OBJECT
public:
  MyThreadObject(){...};
  void setDescriptor(qintptr socketdescriptor)
  {
    m_desc = socketdescriptor;
  }
public slots:
  void initialize()
  {
    m_tcpSocket = new QTcpSocket();
    m_tcpSocket->setSocketDescriptor(m_desc);
    //socket configuration
    m_timer = new QTimer();
    //timer configuration
    m_timer->start();
  }
private:
  QTcpSocket* m_tcpSocket;
  QTimer* m_timer;
  qintptr m_desc;
}
于 2016-12-16T10:47:38.487 回答