欧美一区二区三区老妇人-欧美做爰猛烈大尺度电-99久久夜色精品国产亚洲a-亚洲福利视频一区二区

如何實現(xiàn)STL容器

這篇文章主要介紹了如何實現(xiàn)STL容器的相關(guān)知識,內(nèi)容詳細(xì)易懂,操作簡單快捷,具有一定借鑒價值,相信大家閱讀完這篇如何實現(xiàn)STL容器文章都會有所收獲,下面我們一起來看看吧。

云霄網(wǎng)站建設(shè)公司成都創(chuàng)新互聯(lián),云霄網(wǎng)站設(shè)計制作,有大型網(wǎng)站制作公司豐富經(jīng)驗。已為云霄上千提供企業(yè)網(wǎng)站建設(shè)服務(wù)。企業(yè)網(wǎng)站搭建\成都外貿(mào)網(wǎng)站制作要多少錢,請找那個售后服務(wù)好的云霄做網(wǎng)站的公司定做!

無鎖對象(lock-free object)的正式定義如下 [Her91]:判斷一個共享對象是否為無鎖類型(非阻塞對象),就看它是否能確保一些線程在有限的系統(tǒng)步驟中完成某個操作,并且與其他線程的操作結(jié)果無關(guān)(即便其它線程操作沒有成功)。一個更加嚴(yán)格的非等待對象(wait-free object)是這樣定義的:判斷某個對象是否為非等待,就看每個線程是否是在有限的步驟中完成了在該對象上的操作。無鎖的條件是至少保證一個線程完成任務(wù),而更苛刻的非等待條件則是要保證所有的線程都能成功完成任務(wù)。線性化(linearizability)在競爭數(shù)據(jù)結(jié)構(gòu)上也有理論性的定義[Her90],作為一種標(biāo)準(zhǔn),在驗證無鎖算法正確性方面,發(fā)揮著重要作用。簡而言之,算法是否為線性化的,就看算法完成之后的操作結(jié)果是否顯而易見,不言自明。舉個例子來說,只要插入函數(shù)完成,列表插入操作的結(jié)果就顯而易見的。聽起來很白癡,但沒有人能想出某個算法做了一個列表插入,卻不是線性化。再譬如,各種類型的緩存可能違反這種特性:我們先將一個新元素放入緩存中而非直接插入,接著命令其它線程“將該緩存中的此元素插入列表中”,直到此元素插入進(jìn)去。或者只有當(dāng)緩存中有相當(dāng)數(shù)量的元素時,我們才做一次插入。那么插入函數(shù)執(zhí)行完畢,我們依舊不能保證此元素在列表中。可以確定的是,此元素遲早會被插入到列表中。

下面是一個非常簡單的代碼實現(xiàn):

struct Node {

        Node * m_pNext ;

}; 

class queue {

        Node * m_pHead ;

        Node * m_pTail ;

   public:

        queue(): m_pHead( NULL ), m_pTail( NULL ) {}

        void enqueue( Node * p )

        {

            p->m_pNext = m_pTail ;

            m_pTail = p ;

            if ( !m_pHead )

                m_pHead = p ;

        }

        Node * dequeue()

        {

            if ( !m_pHead ) return NULL ;

            Node * p = m_pHead ;

            m_pHead = p->m_pNext ;

            if ( !m_pHead )

                m_pTail = NULL ;

            return p ;

        }

};

甚至可以寫得更簡短一點,這就是無鎖 Michael&Scott 隊列經(jīng)典算法實現(xiàn)。它看起來就像入隊、出對方法(和壓棧、彈出的意思相同)。(代碼是libcds庫類cds::intrusive::MSQueue簡化版)

bool enqueue( value_type& val )

{

      node_type * pNew = node_traits::to_node_ptr( val );

 

      typename gc::Guard guard;

      back_off bkoff;

 

      node_type * t;

      while ( true ) {

           t = guard.protect( m_pTail, node_to_value() );

 

           node_type * pNext = t->m_pNext.load(memory_model::memory_order_acquire);

           if ( pNext != null_ptr<node_type *>() ) {

                // Tail is misplaced, advance it

                m_pTail.compare_exchange_weak( t, pNext, memory_model::memory_order_release,

                                               CDS_ATOMIC::memory_order_relaxed );

                continue;

           }

 

          node_type * tmp = null_ptr<node_type *>() ;

          if ( t->m_pNext.compare_exchange_strong( tmp, pNew, memory_model::memory_order_release,

                   CDS_ATOMIC::memory_order_relaxed ))

          {

                    break;

          }

          bkoff();

     }

    ++m_ItemCounter;

 

    m_pTail.compare_exchange_strong( t, pNew, memory_model::memory_order_acq_rel,

                                     CDS_ATOMIC::memory_order_relaxed );

 

    return true;  

}

 

value_type * dequeue()

{

     node_type * pNext;

     back_off bkoff;

     typename gc::template GuardArray<2> guards;

 

      node_type * h;

      while ( true ) {

           h = guards.protect( 0, m_pHead, node_to_value() );

           pNext = guards.protect( 1, h->m_pNext, node_to_value() );

           if ( m_pHead.load(memory_model::memory_order_relaxed) != h )

                continue;

 

           if ( pNext == null_ptr<node_type *>() )

                 return NULL; // empty queue

 

           node_type * t = m_pTail.load(memory_model::memory_order_acquire);

           if ( h == t ) {

                // It is needed to help enqueue

               m_pTail.compare_exchange_strong( t, pNext, memory_model::memory_order_release,

                                                CDS_ATOMIC::memory_order_relaxed );

               continue;

           }

 

           if ( m_pHead.compare_exchange_strong( h, pNext,

                     memory_model::memory_order_release, CDS_ATOMIC::memory_order_relaxed ))

           {

                    break;

           }

           bkoff();

     }

 

     --m_ItemCounter;

 

     dispose_node( h );

     return pNext;

}

這是一個很復(fù)雜的算法,相同的單向鏈表。不過即使大體比較一下,也能看出無鎖隊列的一些特征。在無鎖隊列中,我們可以找到如下描述:

  • 無限循環(huán):稍后我們會嘗試執(zhí)行這個操作,這是一個實現(xiàn)了原子性操作compare_exchange的典型模式;

  • 局部變量的安全性(guards),需借助于無鎖算法中安全內(nèi)存收回方法。本例中,為風(fēng)險指針(Hazard Pointers)方法;

  • 采用C++11標(biāo)準(zhǔn)的原子性原語:load、compare_exchange以及內(nèi)存柵欄(memory fences)memory_order_xxx;

  • helping :一種廣泛存在于無鎖算法中的方法,特別是在一個線程幫助其它線程去執(zhí)行任務(wù)場景中;

  • 補(bǔ)償策略(functor bkoff): 這不是必須的,但可以在連接很多的情況下緩解處理器的壓力,尤其是多個線程逐個地調(diào)用隊列時。

關(guān)于“如何實現(xiàn)STL容器”這篇文章的內(nèi)容就介紹到這里,感謝各位的閱讀!相信大家對“如何實現(xiàn)STL容器”知識都有一定的了解,大家如果還想學(xué)習(xí)更多知識,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

本文題目:如何實現(xiàn)STL容器
當(dāng)前路徑:http://chinadenli.net/article28/ggjpcp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供外貿(mào)網(wǎng)站建設(shè)自適應(yīng)網(wǎng)站微信公眾號微信小程序定制網(wǎng)站企業(yè)建站

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)

成都定制網(wǎng)站建設(shè)