微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

多线程 – 如何在使用QThreadPool时执行QObject :: moveToThread()?

我正在构建一个小型多线程Web服务器. QTcpsockets在主线程中获取,然后由QtConcurrent传递给QThreadPool,QThreadPool最终处理数据并发出答案.

我的问题是套接字是在主线程中创建的,并在另一个线程中处理.这在尝试写入套接字时会导致错误

socket->write(somedata);

QObject: Cannot create children for a
parent that is in a different thread.
(Parent is
QNativeSocketEngine(0x608330),
parent’s thread is QThread(0x600630),
current thread is QThread(0x505f60)

干净的方法是使用将套接字对象移动到处理线程

socket->movetoThread(QThread::currentThread()).

但是,这只能在创建对象的线程中调用.此外,套接字将QTcpserver对象作为父对象,因此movetoThread()无论如何都会失败(父对象无法切换线程).

如何在线程池运行的代码中将对象移动到QThread :: currentThread()?或者,如何在创建它的线程之外写入套接字?

解决方法

扩展QTcpserver,重新实现incomingConnection(int socketDescriptor)并将套接字描述符传递给池中的线程.让QRunnable从描述符创建QTcpsocket并启动事件循环以接收该套接字的信号.

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


应用场景 C端用户提交工单、工单创建完成之后、会发布一条工单创建完成的消息事件(异步消息)、MQ消费者收到消息之后、会通知各处理器处理该消息、各处理器处理完后都会发布一条将该工单写入搜索引擎的消息、最终该工单出现在搜索引擎、被工单处理人检索和处理。 事故异常体现 1、异常体现 从工单的流转记录发现、
线程类,设置有一个公共资源 package cn.org.chris.concurrent; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /** * @Descrip
Java中的数字(带有0前缀和字符串)
在Java 9中使用JLink的目的是什么?
Java Stream API Filter(过滤器)
在Java中找到正数和负数数组元素的数量
Java 9中JShell中的不同启动脚本是什么?
使用Java的位填充错误检测技术
java中string是什么
如何使用Java中的JSON-lib API将Map转换为JSON对象?