日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間:8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
基于C++模板,實(shí)現(xiàn)三種異步收發(fā)數(shù)據(jù)的方法

std::future和std::promise兩者結(jié)合可以實(shí)現(xiàn)異步的功能場景,本文將介紹的異步收發(fā)數(shù)據(jù)模版類是在實(shí)踐中結(jié)合std::future和std::promise而摸索出來的。

專業(yè)成都網(wǎng)站建設(shè)公司,做排名好的好網(wǎng)站,排在同行前面,為您帶來客戶和效益!成都創(chuàng)新互聯(lián)公司為您提供成都網(wǎng)站建設(shè),五站合一網(wǎng)站設(shè)計(jì)制作,服務(wù)好的網(wǎng)站設(shè)計(jì)公司,成都網(wǎng)站設(shè)計(jì)、成都做網(wǎng)站負(fù)責(zé)任的成都網(wǎng)站制作公司!

工作過程中,我們可能會經(jīng)常遇到這樣的場景,需要從線程中獲取運(yùn)行的結(jié)果?,F(xiàn)在我們有兩種方式可以實(shí)現(xiàn)這樣的效果。

第一種方式,屬于通用用法,通過使用指針在線程間共享數(shù)據(jù)。傳遞指針給新建的線程,主線程使用條件變量等待被喚醒;當(dāng)線程設(shè)置完成數(shù)據(jù)到傳遞過來的指針之后,發(fā)送條件變量信號,主線程被喚醒之后,從指針中提取數(shù)據(jù)。這種方式采用條件變量、鎖、指針結(jié)合才實(shí)現(xiàn)了異步功能,比較復(fù)雜。

第二種方式,采用std::future和std::promise對象,也就是本文接下來要詳細(xì)說明的一種異步實(shí)現(xiàn)方式。

std::future是一個(gè)類模版,內(nèi)部存儲一個(gè)將來用于分配的值,它提供了get()成員函數(shù)來訪問該值的機(jī)制。如果關(guān)聯(lián)值可用之前,調(diào)用了get函數(shù),那么get函數(shù)將阻塞直到關(guān)聯(lián)值不可用。

std::promise也是一個(gè)類模版,它用來設(shè)置上面的關(guān)聯(lián)值,每一個(gè)stb::promise和一個(gè)std::future對象關(guān)聯(lián),一旦stb::promise設(shè)置值之后,std::future對象的get()函數(shù)就會獲取到值,然后返回。std::promise與它關(guān)聯(lián)的std::future共享數(shù)據(jù)。

一、阻塞等待獲取數(shù)據(jù)

1、實(shí)現(xiàn)線程執(zhí)行函數(shù),入?yún)⑹且粋€(gè)std::promise指針,函數(shù)內(nèi)調(diào)用std::promise指針設(shè)置值

2、定義std::promise對象,從該對象獲取關(guān)聯(lián)的std::future對象,啟動線程并且傳入std::promise對象的指針,調(diào)用std::future對象的get()函數(shù)阻塞等待,如果返回,那么打印輸出返回的字符串信息。

3、運(yùn)行程序,輸出的信息如下所示,從這里可以看出,std::promise在線程中設(shè)置值之后,std::future對象的get()函數(shù)成功獲取并返回。

二、通知線程退出

基于std::promise和std::future的機(jī)制,我們可以利用std::promise的set_value來通知運(yùn)行的線程退出。具體如何做呢,我們接下來給出例子進(jìn)行說明。

1、實(shí)現(xiàn)線程的執(zhí)行函數(shù),入?yún)榕cstd::promise關(guān)聯(lián)的std::future對象,執(zhí)行函數(shù)內(nèi)部調(diào)用std::future的wait_for循環(huán)超時(shí)等待,如果std::future的wait_for在超時(shí)時(shí)間內(nèi)沒有收到std::promise調(diào)用set_value發(fā)送的信號,那么繼續(xù)循環(huán)等待,如果在超時(shí)時(shí)間內(nèi)收到std::promise調(diào)用set_value發(fā)送的信號,那么退出循環(huán),同時(shí)線程也退出了。

2、創(chuàng)建std::promise對象,從std::promise對象提取關(guān)聯(lián)的future對象,啟動線程,并且將上面的future對象傳遞給線程,主線程休眠一段時(shí)間之后,調(diào)用std::promise對象的set_value函數(shù)來發(fā)送信號,通知線程退出

3、從輸出的結(jié)果信息看,線程一直在運(yùn)行,當(dāng)收到std::promise對象發(fā)送信號的信號之后就退出

三、異步收發(fā)數(shù)據(jù)

經(jīng)過上面兩個(gè)例子的講解,相信大家對std::future和std::promise已經(jīng)有了一個(gè)大概的了解。下面就給出異步收發(fā)數(shù)據(jù)的模版類。

1、類模版JAsyncSender實(shí)現(xiàn)兩個(gè)函數(shù),一個(gè)是Send用于發(fā)送數(shù)據(jù),它可以在線程中執(zhí)行,另一個(gè)是Wait等待接收數(shù)據(jù),如果第三個(gè)參數(shù)沒有輸入,那么默認(rèn)一直等待,否則在指定時(shí)間內(nèi),沒有收到信息,那么返回失敗

2、接下來說明類模版JAsyncSender的使用方法

定義成員變量m_AsyncSendInt,它由主線程和子線程共享。JAsyncSender的type為整型,也可以定義為字符串,甚至是自定義對象,根據(jù)具體需求場景具體定義。

通過lambda方式創(chuàng)建線程,當(dāng)然你也可以使用其他方式,線程內(nèi)部先休眠一段時(shí)間,然后發(fā)送數(shù)據(jù)。

從運(yùn)行結(jié)果看,基于future和promise實(shí)現(xiàn)的異步收發(fā)數(shù)據(jù)模版類的功能是正常的。

四、總結(jié)

std::promise與std::future的結(jié)合使用,可以更加容易處理異步消息事件,另外C++11標(biāo)準(zhǔn)中提供的 std::asych和std::packaged_task也是結(jié)合std::future來處理異步的事件流程。std::promise與std::future雖然功能強(qiáng)大,但是std::promise與std::future是一一對應(yīng)的,目前沒有辦法處理一對多的問題,比如一個(gè)std::promise對應(yīng)多個(gè)std::future。std::promise如果設(shè)置過一次,再次設(shè)置會報(bào)錯(cuò),如果需要重新使用,需要再創(chuàng)建std::promise對象。


分享題目:基于C++模板,實(shí)現(xiàn)三種異步收發(fā)數(shù)據(jù)的方法
網(wǎng)站網(wǎng)址:http://www.5511xx.com/article/ccegjho.html