X-Git-Url: http://demsky.eecs.uci.edu/git/?a=blobdiff_plain;f=cds%2Fcontainer%2Fimpl%2Flazy_list.h;h=96c37b814fac248c5fcc15f818c659a6c7627ac2;hb=6924946ceeaae28bc227fe7c9d8e939963bb9d69;hp=6b7efb574bf551a37648d46c7f6fdb84cc4e6e3b;hpb=4cfc2b411754b8a33010c95776bf97e70ee89b95;p=libcds.git diff --git a/cds/container/impl/lazy_list.h b/cds/container/impl/lazy_list.h index 6b7efb57..96c37b81 100644 --- a/cds/container/impl/lazy_list.h +++ b/cds/container/impl/lazy_list.h @@ -1,11 +1,11 @@ /* This file is a part of libcds - Concurrent Data Structures library - (C) Copyright Maxim Khizhinsky (libcds.dev@gmail.com) 2006-2016 + (C) Copyright Maxim Khizhinsky (libcds.dev@gmail.com) 2006-2017 Source code repo: http://github.com/khizmax/libcds/ Download: http://sourceforge.net/projects/libcds/files/ - + Redistribution and use in source and binary forms, with or without modification, are permitted provided that the following conditions are met: @@ -144,6 +144,22 @@ namespace cds { namespace container { static CDS_CONSTEXPR const size_t c_nHazardPtrCount = base_class::c_nHazardPtrCount; ///< Count of hazard pointer required for the algorithm + //@cond + // Rebind traits (split-list support) + template + struct rebind_traits { + typedef LazyList< + gc + , value_type + , typename cds::opt::make_options< traits, Options...>::type + > type; + }; + + // Stat selector + template + using select_stat_wrapper = typename base_class::template select_stat_wrapper< Stat >; + //@endcond + protected: //@cond typedef typename base_class::value_type node_type; @@ -152,40 +168,6 @@ namespace cds { namespace container { typedef typename maker::intrusive_traits::compare intrusive_key_comparator; typedef typename base_class::node_type head_type; - //@endcond - - public: - /// Guarded pointer - typedef typename gc::template guarded_ptr< node_type, value_type, details::guarded_ptr_cast_set > guarded_ptr; - - protected: - //@cond - static value_type& node_to_value( node_type& n ) - { - return n.m_Value; - } - - static value_type const& node_to_value( node_type const& n ) - { - return n.m_Value; - } - - template - static node_type * alloc_node( Q const& v ) - { - return cxx_allocator().New( v ); - } - - template - static node_type * alloc_node( Args&&... args ) - { - return cxx_allocator().MoveNew( std::forward(args)... ); - } - - static void free_node( node_type * pNode ) - { - cxx_allocator().Delete( pNode ); - } struct node_disposer { void operator()( node_type * pNode ) @@ -193,35 +175,20 @@ namespace cds { namespace container { free_node( pNode ); } }; - typedef std::unique_ptr< node_type, node_disposer > scoped_node_ptr; + typedef std::unique_ptr< node_type, node_disposer > scoped_node_ptr; - head_type& head() - { - return base_class::m_Head; - } - - head_type const& head() const - { - return base_class::m_Head; - } - - head_type& tail() - { - return base_class::m_Tail; - } - - head_type const& tail() const - { - return base_class::m_Tail; - } //@endcond + public: + /// Guarded pointer + typedef typename gc::template guarded_ptr< node_type, value_type, details::guarded_ptr_cast_set > guarded_ptr; + protected: - //@cond + //@cond template class iterator_type: protected base_class::template iterator_type { - typedef typename base_class::template iterator_type iterator_base; + typedef typename base_class::template iterator_type iterator_base; iterator_type( head_type const& pNode ) : iterator_base( const_cast( &pNode )) @@ -240,7 +207,7 @@ namespace cds { namespace container { iterator_type() {} - iterator_type( const iterator_type& src ) + iterator_type( iterator_type const& src ) : iterator_base( src ) {} @@ -306,7 +273,7 @@ namespace cds { namespace container { */ iterator begin() { - iterator it( head() ); + iterator it( head()); ++it ; // skip dummy head node return it; } @@ -320,13 +287,13 @@ namespace cds { namespace container { */ iterator end() { - return iterator( tail() ); + return iterator( tail()); } /// Returns a forward const iterator addressing the first element in a list const_iterator begin() const { - const_iterator it( head() ); + const_iterator it( head()); ++it ; // skip dummy head node return it; } @@ -334,7 +301,7 @@ namespace cds { namespace container { /// Returns a forward const iterator addressing the first element in a list const_iterator cbegin() const { - const_iterator it( head() ); + const_iterator it( head()); ++it ; // skip dummy head node return it; } @@ -342,13 +309,13 @@ namespace cds { namespace container { /// Returns an const iterator that addresses the location succeeding the last element in a list const_iterator end() const { - return const_iterator( tail() ); + return const_iterator( tail()); } /// Returns an const iterator that addresses the location succeeding the last element in a list const_iterator cend() const { - return const_iterator( tail() ); + return const_iterator( tail()); } //@} @@ -382,9 +349,9 @@ namespace cds { namespace container { Returns \p true if inserting successful, \p false otherwise. */ template - bool insert( Q const& val ) + bool insert( Q&& val ) { - return insert_at( head(), val ); + return insert_at( head(), std::forward( val )); } /// Inserts new node @@ -410,9 +377,9 @@ namespace cds { namespace container { it is preferable that the initialization should be completed only if inserting is successful. */ template - bool insert( Q const& key, Func func ) + bool insert( Q&& key, Func func ) { - return insert_at( head(), key, func ); + return insert_at( head(), std::forward( key ), func ); } /// Inserts data of type \p value_type constructed from \p args @@ -436,14 +403,14 @@ namespace cds { namespace container { The functor \p Func signature is: \code struct my_functor { - void operator()( bool bNew, value_type& item, Q const& val ); + void operator()( bool bNew, value_type& item, Q const& key ); }; \endcode with arguments: - \p bNew - \p true if the item has been inserted, \p false otherwise - \p item - item of the list - - \p val - argument \p key passed into the \p %update() function + - \p key - argument \p key passed into the \p %update() function The functor may change non-key fields of the \p item; during \p func call \p item is locked so it is safe to modify the item in @@ -565,9 +532,7 @@ namespace cds { namespace container { template guarded_ptr extract( Q const& key ) { - guarded_ptr gp; - extract_at( head(), gp.guard(), key, intrusive_key_comparator() ); - return gp; + return extract_at( head(), key, intrusive_key_comparator()); } /// Extracts the item from the list with comparing functor \p pred @@ -583,9 +548,7 @@ namespace cds { namespace container { guarded_ptr extract_with( Q const& key, Less pred ) { CDS_UNUSED( pred ); - guarded_ptr gp; - extract_at( head(), gp.guard(), key, typename maker::template less_wrapper::type() ); - return gp; + return extract_at( head(), key, typename maker::template less_wrapper::type()); } /// Checks whether the list contains \p key @@ -596,7 +559,7 @@ namespace cds { namespace container { template bool contains( Q const& key ) { - return find_at( head(), key, intrusive_key_comparator() ); + return find_at( head(), key, intrusive_key_comparator()); } //@cond template @@ -617,7 +580,7 @@ namespace cds { namespace container { bool contains( Q const& key, Less pred ) { CDS_UNUSED( pred ); - return find_at( head(), key, typename maker::template less_wrapper::type() ); + return find_at( head(), key, typename maker::template less_wrapper::type()); } //@cond template @@ -712,9 +675,7 @@ namespace cds { namespace container { template guarded_ptr get( Q const& key ) { - guarded_ptr gp; - get_at( head(), gp.guard(), key, intrusive_key_comparator() ); - return gp; + return get_at( head(), key, intrusive_key_comparator()); } /// Finds the key \p key and return the item found @@ -730,9 +691,7 @@ namespace cds { namespace container { guarded_ptr get_with( Q const& key, Less pred ) { CDS_UNUSED( pred ); - guarded_ptr gp; - get_at( head(), gp.guard(), key, typename maker::template less_wrapper::type() ); - return gp; + return get_at( head(), key, typename maker::template less_wrapper::type()); } /// Checks whether the list is empty @@ -768,6 +727,53 @@ namespace cds { namespace container { protected: //@cond + static value_type& node_to_value( node_type& n ) + { + return n.m_Value; + } + + static value_type const& node_to_value( node_type const& n ) + { + return n.m_Value; + } + + template + static node_type * alloc_node( Q const& v ) + { + return cxx_allocator().New( v ); + } + + template + static node_type * alloc_node( Args&&... args ) + { + return cxx_allocator().MoveNew( std::forward( args )... ); + } + + static void free_node( node_type * pNode ) + { + cxx_allocator().Delete( pNode ); + } + + head_type& head() + { + return base_class::m_Head; + } + + head_type const& head() const + { + return base_class::m_Head; + } + + head_type& tail() + { + return base_class::m_Tail; + } + + head_type const& tail() const + { + return base_class::m_Tail; + } + bool insert_node( node_type * pNode ) { return insert_node_at( head(), pNode ); @@ -787,9 +793,9 @@ namespace cds { namespace container { } template - bool insert_at( head_type& refHead, const Q& val ) + bool insert_at( head_type& refHead, Q&& val ) { - return insert_node_at( refHead, alloc_node( val )); + return insert_node_at( refHead, alloc_node( std::forward( val ))); } template @@ -799,11 +805,11 @@ namespace cds { namespace container { } template - bool insert_at( head_type& refHead, const Q& key, Func f ) + bool insert_at( head_type& refHead, Q&& key, Func f ) { - scoped_node_ptr pNode( alloc_node( key )); + scoped_node_ptr pNode( alloc_node( std::forward( key ))); - if ( base_class::insert_at( &refHead, *pNode, [&f](node_type& node){ f( node_to_value(node) ); } )) { + if ( base_class::insert_at( &refHead, *pNode, [&f](node_type& node){ f( node_to_value(node)); } )) { pNode.release(); return true; } @@ -811,24 +817,24 @@ namespace cds { namespace container { } template - bool erase_at( head_type& refHead, const Q& key, Compare cmp, Func f ) + bool erase_at( head_type& refHead, Q const& key, Compare cmp, Func f ) { - return base_class::erase_at( &refHead, key, cmp, [&f](node_type const& node){ f( node_to_value(node) ); } ); + return base_class::erase_at( &refHead, key, cmp, [&f](node_type const& node){ f( node_to_value(node)); } ); } template - bool extract_at( head_type& refHead, typename guarded_ptr::native_guard& guard, Q const& key, Compare cmp ) + guarded_ptr extract_at( head_type& refHead, Q const& key, Compare cmp ) { - return base_class::extract_at( &refHead, guard, key, cmp ); + return base_class::extract_at( &refHead, key, cmp ); } template - std::pair update_at( head_type& refHead, const Q& key, Func f, bool bAllowInsert ) + std::pair update_at( head_type& refHead, Q const& key, Func f, bool bAllowInsert ) { scoped_node_ptr pNode( alloc_node( key )); std::pair ret = base_class::update_at( &refHead, *pNode, - [&f, &key](bool bNew, node_type& node, node_type&){f( bNew, node_to_value(node), key );}, + [&f, &key](bool bNew, node_type& node, node_type&) { f( bNew, node_to_value(node), key );}, bAllowInsert ); if ( ret.first && ret.second ) pNode.release(); @@ -845,13 +851,13 @@ namespace cds { namespace container { template bool find_at( head_type& refHead, Q& val, Compare cmp, Func f ) { - return base_class::find_at( &refHead, val, cmp, [&f](node_type& node, Q& val){ f( node_to_value(node), val ); }); + return base_class::find_at( &refHead, val, cmp, [&f](node_type& node, Q& v){ f( node_to_value(node), v ); }); } template - bool get_at( head_type& refHead, typename guarded_ptr::native_guard& guard, Q const& key, Compare cmp ) + guarded_ptr get_at( head_type& refHead, Q const& key, Compare cmp ) { - return base_class::get_at( &refHead, guard, key, cmp ); + return base_class::get_at( &refHead, key, cmp ); } //@endcond