QObject::connect在QRunnable中的应用 - 控制台

Question

我将创建一个简单的多线程服务器：

• 创建服务器
• 如果有新连接，则创建新的QThreadpool-QRunnable
• 在可运行对象中向客户端发送消息并等待请求
• 如果客户端已断开连接，则可运行对象将写入QDebug并退出。

server.h

class Server : public QTcpServer
{
Q_OBJECT
public:
explicit Server(QObject *parent = 0);
void StartServer();

protected:
void incomingConnection(int handle);

private:
QThreadPool *pool;
};

server.cpp:

#include "server.h"

Server::Server(QObject *parent) :
QTcpServer(parent)
{
pool = new QThreadPool(this);
pool->setMaxThreadCount(10);
}

void Server::StartServer()
{
this->listen(QHostAddress(dts.ipAddress),80));
}

void Server::incomingConnection(int handle)
{
Runnable *task = new Runnable();
task->setAutoDelete(true);

task->SocketDescriptor = handle;
pool->start(task);
}

runnable.h

class Runnable : public QRunnable
{
public:
Runnable();
int SocketDescriptor;

protected:
void run();

public slots:
void disconnectCln();
};

runnable.cpp

#include "runnable.h"

Runnable::Runnable()
{

}

void Runnable::run()
{
if(!SocketDescriptor) return;

QTcpSocket *newSocketCon = new QTcpSocket();
newSocketCon->setSocketDescriptor(SocketDescriptor);

如何实现？

使用QObgect::connect函数，将newSocketCon的disconnected信号连接到this对象的disconnectCln槽函数上。

newSocketCon->write(mes.toUtf8().data());
newSocketCon->flush();
newSocketCon->waitForBytesWritten();
}

void Runnable::disconnectCln()
{
qDebug() << "Client was disconnect";
}

- user2444842

Answer 1

您似乎忘记了实际提出问题，但这是我在您的代码中立即发现的问题：您的Runnable类没有继承QObject，因此无法具有信号和槽。您需要这样做才能有任何希望使其工作。

class Runnable : public QObject, public QRunnable
{
  Q_OBJECT
public:
  Runnable();
  int SocketDescriptor;

protected:
  void run();

public slots:
  void disconnectCln();
};

这里有两点需要注意。1) 如果你使用多重继承，QObject必须放在继承列表的第一位。2) 如果要使用信号和槽，你必须在类定义中包含Q_OBJECT宏。

- Dan Milburn

---

非常感谢！ :) - user2444842