我有一个 QTcpSocket,我需要控制它 - 使用多线程写入+读取。
这在 QT4 中工作正常,但在 QT5 中我收到此错误,似乎只有 1 个线程可以同时访问套接字。如何使一个套接字能够被多个线程访问?
基本上我想创建 1 个用于读取的线程和 1 个用于写入数据的线程,以便我可以异步读取和处理数据,同时在应用程序的其余部分执行其他操作。
注意:对Qt - 在新线程中处理 QTcpSocket 的回答在这里没有帮助,因为它描述了如何将套接字从线程 1 传输到线程 2,然后仅从线程 2 使用它。我需要从两个线程使用它。
您只能从一个线程直接与套接字交互(该线程必须运行一个事件循环 - 因此您应该在其上调用
exec()
)。如果您想从另一个线程读取/写入,则需要使用信号/槽。
使用默认连接类型 (
Qt::AutoConnection
) 将一个线程上发出的 Signal 连接到另一个线程上对象的 Slot 将自动确保发生安全的线程传输(使用排队连接)。您可以使用 Qt::QueuedConnection
将信号显式连接到插槽,但 Qt::AutoConnection
应该可以正常工作。
// Lives on thread 1
class MySocketOwner : public QObject
{
Q_OBJECT
public:
MySocketOwner(QObject *Parent = 0)
: QObject(Parent)
{
Socket = new QTcpSocket(this);
connect(Socket, SIGNAL(readyRead()), this, SLOT(Read()));
}
~MySocketOwner()
{
delete Socket;
}
public slots:
void Read()
{
QByteArray Data = Socket->readAll();
// Do something with the data
}
void Write(QBytrArray Data)
{
// Must always be called on thread 1
Socket->write(Data);
}
private:
QTcpSocket *Socket;
};
// Lives on thread 2
class MySocketWriter : public QObject
{
Q_OBJECT
public:
MySocketWriter(QObject *Parent = 0)
: QObject(Parent)
{
// If this is on another thread, connection will be queued
connect(this, SIGNAL(Write(QByteArray)), MySocketOwnerPointer, SLOT(Write(QBytrArray Data)));
QByteArray Data;
// Fill with data
// An event gets put onto thread 1's event queue after this
emit Write(Data);
}
signals:
void Write(QByteArray Data);
};
就像对你的问题的评论所说,你需要仔细考虑为什么你需要这种行为,你真的需要在2个单独的线程上读取套接字接收到的相同数据吗?