温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Qt如何实现线程同步

发布时间:2022-01-13 15:19:30 阅读:318 作者:iii 栏目:大数据
开发者测试专用服务器限时活动,0元免费领,库存有限,领完即止! 点击查看>>

本篇内容介绍了“Qt如何实现线程同步”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!

问题的提出

线程安全的数据类可以提供一种便利的手段来进行线程之间的数据交换,但是这种方法并没有协调两个线程的动作,这一点从输出结果也可以看出:

Qt如何实现线程同步

从输出可以看出,数据交换要么成功,要么就根本不能进行。这就是线程间没有同步的结果。解决这个问题就需要线程同步处理。

示例代码

本例中定义两个互斥量,dataReady和bufferReady。

void WriteData(int i,                QMutex& dataReady,                QMutex& bufferReady){    bufferReady.lock();    cout << "WT:<<<<WriteData:" <<            i << "<<<<" << endl;    int buffer[5];    for(int j = 0; j < 5; ++j)    {        buffer[j] = j;    }    data_array.setData(buffer, 5);    dataReady.unlock();}

WriteData方法首先尝试对bufferReady加锁,如果数据类中没有数据时,加锁操作成功,接下来按照正常逻辑写入数据,最后dataReady解锁,为ReadData创造执行条件。

void ReadData(int i,               QMutex& dataReady,             QMutex& bufferReady){    dataReady.lock();    cout << "RT:>>>>ReadData:" <<            i << ">>>>" << endl;    int buffer[5];    int data_size =        data_array.removeData(buffer, 5);    cout << "RT::----data_size=" <<            data_size << endl;    int total = 0;    for(int k = 0; k < data_size; ++k)    {        total += buffer[k];    }    cout << "RT:----total="  <<                     total << endl;    bufferReady.unlock();}

ReadData方法首先尝试对dataReady加锁,如果数据类中存在数据时,加锁操作成功,接下来按照正常逻辑读出数据,最后对bufferReady解锁,为WriteData创造执行条件。

int main(int /*argc*/, char*[] /*argv*/){    //define CreateDataTask class.    class CreateDataTask : public QThread    {        QMutex& m_data;        QMutex& m_buffer;    public:        CreateDataTask(QMutex& dataReady,                        QMutex& bufferReady)            :m_data(dataReady)            ,m_buffer(bufferReady)        {        }    private:        void run()        {            for(int i = 0; i < 10; ++i)            {                WriteData(i, m_data, m_buffer);            }        }    };
    QMutex dataReady;    QMutex bufferReady;
    ::timeBeginPeriod(1);    dataReady.lock();    //Create thread object of CreateDataTask.    CreateDataTask *writer =       new CreateDataTask(dataReady,                            bufferReady);    //Start Thread.    writer->start(QThread::NormalPriority);    for(int i = 0; i < 10; ++i)    {        ReadData(i, dataReady, bufferReady);    }    timeEndPeriod(1);    getch();        return 0;}

Main函数中创建了两个互斥量,dataReady和bufferReady,用于读数据操作和和写数据操作。

由于最初没有写入的数据,所以首先调用dataReaday.lock操作,使读数据线程处于阻塞状态。

CreateDataTask类没有另外创建互斥量,而是使用构造函数传递的两个互斥量,然后再传递给WriteData函数。

执行结果

Qt如何实现线程同步

写数据操作,读数据操作整齐地间隔排列,同时数据传递全部正确!

“Qt如何实现线程同步”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站,小编将为大家输出更多高质量的实用文章!

亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

原文链接:https://my.oschina.net/u/4579737/blog/4601230

qt
AI

开发者交流群×