QSharedMemory使用例子_QSharedMemory不同进程资源-CSDN下载

共12个文件

cpp：4个

h：2个

ui：2个

Memory

共享内存

源码

5星 · 超过95%的资源需积分: 48 197 浏览量 2015-06-25 20:57:57 上传评论收藏 11KB ZIP 举报

在本文中，我们将深入探讨`QSharedMemory`的使用，这是一种在Qt库中实现的用于跨进程通信的重要工具。`QSharedMemory`允许不同进程之间共享数据，通过内存区域进行直接交互，从而提高效率并简化多进程应用的设计。我们将通过分析标题提到的`QSharedMemory`使用例子，包括读取和写入程序，来了解如何操作共享内存。我们要理解`QSharedMemory`的基本用法。在创建`QSharedMemory`对象时，我们需要提供一个键（key），这个键是用于标识共享内存块的字符串。在写程序中，我们通常会先尝试创建共享内存块，如果成功，我们就可以将数据写入其中。代码可能如下： ```cpp QSharedMemory sharedMemory("mySharedKey"); if (!sharedMemory.create(sizeof(data), QSharedMemory::ReadOnly)) { // 处理创建失败的情况 } memcpy(sharedMemory.data(), &data, sizeof(data)); ``` 这里，`create`函数用于创建指定大小的内存块，`ReadOnly`表明写入完成后，内存将变为只读模式。`data`是我们要写入的数据，`memcpy`函数将其复制到共享内存中。读程序则会在自己的进程中查找相同的共享内存键。如果找到，它可以在子线程中持续读取数据。以下是一个简单的读取示例： ```cpp QSharedMemory sharedMemory("mySharedKey"); if (sharedMemory.attach()) { while (true) { if (sharedMemory.isAttached()) { // 读取数据 MyDataType data; memcpy(&data, sharedMemory.data(), sizeof(data)); // 处理读取到的数据 } else { // 重新尝试连接或处理断开的情况 // ... } } } else { // 处理无法附加的情况 } ``` 在读程序中，我们使用`attach`方法连接到共享内存，然后在循环中读取数据。`isAttached`检查当前是否已连接，确保在读取之前连接成功。值得注意的是，`QSharedMemory`提供了线程安全的访问，因此在子线程中读取是安全的。但为了防止数据竞争，通常需要在写入时锁定内存，或者采用信号量等同步机制来协调读写操作。在这个例子中，`testWriteShareMemory`可能是写入数据的程序，而`testReadShareMemory`则是读取数据的程序。这两个程序应该分别实现上述的逻辑，通过共享内存进行通信。在实际项目中，它们可能还需要处理更多的异常情况，例如共享内存已存在但内容被其他进程修改，或者内存无法创建、附加等情况。 `QSharedMemory`提供了一种高效且灵活的跨进程通信方式，使得多个进程能够共享和交换数据。通过阅读和理解这两个示例程序，我们可以更好地掌握`QSharedMemory`的使用，并将其应用到自己的Qt项目中。记住，正确地管理和同步共享内存是确保数据一致性并避免错误的关键。

资源推荐

资源详情

资源评论

收起资源包目录

testShareMemory.zip （12个子文件）

testWriteShareMemory

mainwindow.ui 2KB

mainwindow.cpp 3KB

main.cpp 183B

mainwindow.h 734B

testWriteShareMemory.pro 393B

testWriteShareMemory.pro.user 18KB

testReadShareMemory

testReadShareMemory.pro.user 18KB

mainwindow.ui 1KB

mainwindow.cpp 4KB

testReadShareMemory.pro 392B

main.cpp 183B

mainwindow.h 1KB

#include "mainwindow.h" #include "ui_mainwindow.h" //注意：读取方打开方式为Open QSystemSemaphore MainWindow::s_freeSystemSem("freeSemaphore", 1, QSystemSemaphore::Open); QSystemSemaphore MainWindow::s_usedSystemSem("usedSemaphore", 1, QSystemSemaphore::Open); MainWindow::MainWindow(QWidget *parent) : QMainWindow(parent), ui(new Ui::MainWindow) { ui->setupUi(this); this->setWindowTitle("Read ShareMemory"); connect(this,SIGNAL(sigExit()),this,SLOT(slotExit())); connect(this,SIGNAL(sigRecvData(QString)),this,SLOT(slotRecvData(QString))); initShareMem(); m_pCReadThread = new CShareMemReadThread(this); m_pCReadThread->start(); } MainWindow::~MainWindow() { delete ui; detachShareMem(); } void MainWindow::slotExit() { qApp->exit(); } void MainWindow::slotRecvData(QString data) { if(0 == data.compare(tr("app exit"))) { qApp->exit(); return; } ui->textBrowser->append(data); } void MainWindow::notifyRecvData() { emit sigRecvData(tr(m_recvBuf)); } void MainWindow::notifyExit() { emit sigExit(); } /************************************************************ 功能：初始化共享内存参数：返回：>=0，成功； <0，失败作者：刘远安 2015-06-23 ************************************************************/ int MainWindow::initShareMem() { int ret = -1; m_sharedMem.setKey("FrontCommunicationSharedMemory"); if (m_sharedMem.isAttached()) { if(!m_sharedMem.detach()) { qWarning("WriteSharedMemory : detach failed."); return ret; } } else { qWarning("ReadSharedMemory:: attach success."); } return 0; } /************************************************************ 功能：释放共享内存参数：返回：>=0，成功； <0，失败作者：刘远安 2015-06-23 ************************************************************/ int MainWindow::detachShareMem() { int ret = -1; if (m_sharedMem.isAttached()) { qWarning("ShareMem is attached"); if(!m_sharedMem.detach()) { qWarning("WriteSharedMemory:: detach failed."); return ret; } else { qWarning("WriteSharedMemory:: detached success."); } } return 0; } /************************************************************ 功能：读取共享内存数据参数：返回：>=0，成功； <0，失败作者：刘远安 2015-06-23 ************************************************************/ int MainWindow::readShareMem() { int ret = -1; if(m_sharedMem.isAttached()) { qWarning("ReadSharedMemory:: haved attached."); } else { if(!m_sharedMem.attach()) { //If an attempt of reading from the shared memory before data is written QSharedMemory::SharedMemoryError m = m_sharedMem.error(); qWarning("ReadSharedMemory:: attach failed."); return ret; } else { qWarning("ReadSharedMemory:: attach success."); } } s_usedSystemSem.acquire(); m_sharedMem.lock(); char *buf = (char*)m_sharedMem.constData(); m_recvLen = strlen(buf); if(m_recvLen > 0) { memset(m_recvBuf,0,sizeof(m_recvBuf)); memcpy(m_recvBuf,buf,m_recvLen); } //清空缓存 buf = (char*)m_sharedMem.data(); memset(buf,0,m_sharedMem.size()); m_sharedMem.unlock(); s_freeSystemSem.release(); return m_recvLen; } CShareMemReadThread::CShareMemReadThread(MainWindow *pMainWindow) { m_pMainWindow = pMainWindow; } CShareMemReadThread::~CShareMemReadThread() { } void CShareMemReadThread::run() { while (1) { int readLen = m_pMainWindow->readShareMem(); qWarning("readLen=%d",readLen); if(readLen > 0) { m_pMainWindow->notifyRecvData(); } msleep(100); } return; }

评论收藏

内容反馈