thread_safe_list.h

#ifndef THREAD_SAFE_LIST_H_INCLUDED
#define THREAD_SAFE_LIST_H_INCLUDED

#include <list>
#include <boost/thread.hpp>

namespace thread_safe {

template < class T, class Allocator = std::allocator<T> >
class list {
public:
    typedef typename std::list<T, Allocator>::iterator iterator;
    typedef typename std::list<T, Allocator>::const_iterator const_iterator;
    typedef typename std::list<T, Allocator>::reverse_iterator reverse_iterator;
    typedef typename std::list<T, Allocator>::const_reverse_iterator const_reverse_iterator;
    typedef typename std::list<T, Allocator>::allocator_type allocator_type;
    typedef typename std::list<T, Allocator>::value_type value_type;
    typedef typename std::list<T, Allocator>::size_type size_type;
    typedef typename std::list<T, Allocator>::difference_type difference_type;

    //Constructor
    explicit list( const Allocator & alloc = Allocator() ) : storage( alloc ) { }
    explicit list( size_type n, const T & value = T(), const Allocator & alloc = Allocator() ) : storage( n, value, alloc ) { }
    template <class InputIterator> list( InputIterator first, InputIterator last, const Allocator & alloc = Allocator() ) : storage( first, last, alloc ) { }
    list( const thread_safe::list<T, Allocator> & x ) { boost::lock_guard<boost::mutex> lock( x.mutex ); storage = x.storage; }

    //Copy
    thread_safe::list<T,Allocator>& operator=( const thread_safe::list<T,Allocator>& x ) { boost::lock_guard<boost::mutex> lock( mutex ); boost::lock_guard<boost::mutex> lock2( x.mutex ); storage = x.storage; return *this;}

    //Destructor
    ~list<T,Allocator>( void ) { }

    //Iterators
    iterator begin( void ) { boost::lock_guard<boost::mutex> lock( mutex ); return storage.begin(); }
    const_iterator begin( void ) const { boost::lock_guard<boost::mutex> lock( mutex ); return storage.begin(); }

    iterator end( void ) { boost::lock_guard<boost::mutex> lock( mutex ); return storage.end(); }
    const_iterator end( void ) const { boost::lock_guard<boost::mutex> lock( mutex ); return storage.end(); }

    reverse_iterator rbegin( void ) { boost::lock_guard<boost::mutex> lock( mutex ); return storage.rbegin(); }
    const_reverse_iterator rbegin( void ) const { boost::lock_guard<boost::mutex> lock( mutex ); return storage.rbegin(); }

    reverse_iterator rend( void ) { boost::lock_guard<boost::mutex> lock( mutex ); return storage.rend(); }
    const_reverse_iterator rend( void ) const { boost::lock_guard<boost::mutex> lock( mutex ); return storage.rend(); }

    //Capacity
    size_type size( void ) const { boost::lock_guard<boost::mutex> lock( mutex ); return storage.size(); }

    size_type max_size( void ) const { boost::lock_guard<boost::mutex> lock( mutex ); return storage.max_size(); }

    void resize( size_type n, T c = T() ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.resize( n, c ); }

    bool empty( void ) const { boost::lock_guard<boost::mutex> lock( mutex ); return storage.empty(); }

    //Element access
    T & front( void ) { boost::lock_guard<boost::mutex> lock( mutex ); return storage.front(); }
    const T & front( void ) const { boost::lock_guard<boost::mutex> lock( mutex ); return storage.back(); }

    T & back( void ) { boost::lock_guard<boost::mutex> lock( mutex ); return storage.back(); }
    const T & back( void ) const { boost::lock_guard<boost::mutex> lock( mutex ); return storage.back(); }

    //Modifiers
    void assign( size_type n, T & u ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.assign( n, u ); }
    template <class InputIterator> void assign( InputIterator begin, InputIterator end ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.assign( begin, end ); }

    void push_back( const T & u ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.push_back( u ); }

    void pop_back( void ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.pop_back(); }

    void push_front( const T & u ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.push_front( u ); }

    void pop_front( void ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.pop_front(); }

    iterator insert( iterator pos, const T & u ) { boost::lock_guard<boost::mutex> lock( mutex ); return storage.insert( pos, u ); }
    void insert( iterator pos, size_type n, const T & u ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.insert( pos, n, u ); }
    template <class InputIterator> void insert( iterator pos, InputIterator begin, InputIterator end ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.insert( pos, begin, end ); }

    void erase( iterator pos ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.erase( pos ); }
    void erase( iterator begin, iterator end ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.erase( begin, end ); }

    void swap( thread_safe::list<T, Allocator> & x ) { boost::lock_guard<boost::mutex> lock( mutex ); boost::lock_guard<boost::mutex> lock2( x.mutex ); storage.swap( x.storage ); }

    void clear( void ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.clear(); }

    //Operations
    void splice ( iterator position, thread_safe::list<T,Allocator>& x ) { boost::lock_guard<boost::mutex> lock( mutex ); boost::lock_guard<boost::mutex> lock2( x.mutex ); storage.splice( position, x.storage ); }
    void splice ( iterator position, thread_safe::list<T,Allocator>& x, iterator i ) { boost::lock_guard<boost::mutex> lock( mutex ); boost::lock_guard<boost::mutex> lock2( x.mutex ); storage.splice( position, x.storage, i ); }
    void splice ( iterator position, thread_safe::list<T,Allocator>& x, iterator first, iterator last ) { boost::lock_guard<boost::mutex> lock( mutex ); boost::lock_guard<boost::mutex> lock2( x.mutex ); storage.splice( position, x.storage, first, last ); }

    void remove ( const T& value ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.remove( value ); }

    template <class Predicate> void remove_if ( Predicate pred ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.remove_if( pred ); }

    void unique ( void ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.unique(); }
    template <class BinaryPredicate> void unique ( BinaryPredicate binary_pred ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.unique( binary_pred ); }

    void merge ( thread_safe::list<T,Allocator>& x ) { boost::lock_guard<boost::mutex> lock( mutex ); boost::lock_guard<boost::mutex> lock2( x.mutex ); storage.merge( x.storage() ); }
    template <class Compare> void merge ( thread_safe::list<T,Allocator>& x, Compare comp ) { boost::lock_guard<boost::mutex> lock( mutex ); boost::lock_guard<boost::mutex> lock2( x.mutex ); storage.merge( x.storage, comp ); }

    void sort ( void ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.sort(); }
    template <class Compare> void sort ( Compare comp ) { boost::lock_guard<boost::mutex> lock( mutex ); storage.sort( comp ); }

    void reverse( void ) { boost::lock_guard<boost::mutex> lock( mutex ); }

    //Allocator
    allocator_type get_allocator( void ) const { boost::lock_guard<boost::mutex> lock( mutex ); return storage.get_allocator(); }

private:
    std::list<T, Allocator> storage;
    mutable boost::mutex mutex;
};

}

#endif // THREAD_SAFE_LIST_H_INCLUDED