{

Lockable mtx_;

atomic<thread::id> id_;

public:

/// the type of the wrapped lockable

typedef Lockable lockable_type;

/// Non copyable

BOOST_THREAD_NO_COPYABLE(testable_mutex)

testable_mutex() : id_(thread::id()) {}

void lock()

{

BOOST_ASSERT(! is_locked_by_this_thread());

mtx_.lock();

id_ = this_thread::get_id();

}

void unlock()

{

BOOST_ASSERT(is_locked_by_this_thread());

id_ = thread::id();

mtx_.unlock();

}

bool try_lock()

{

BOOST_ASSERT(! is_locked_by_this_thread());

if (mtx_.try_lock())

{

id_ = this_thread::get_id();

return true;

}

else

{

return false;

}

}

#ifdef BOOST_THREAD_USES_CHRONO

template <class Rep, class Period>

bool try_lock_for(const chrono::duration<Rep, Period>& rel_time)

{

BOOST_ASSERT(! is_locked_by_this_thread());

if (mtx_.try_lock_for(rel_time))

{

id_ = this_thread::get_id();

return true;

}

else

{

return false;

}

}

template <class Clock, class Duration>

bool try_lock_until(const chrono::time_point<Clock, Duration>& abs_time)

{

BOOST_ASSERT(! is_locked_by_this_thread());

if (mtx_.try_lock_until(abs_time))

{

id_ = this_thread::get_id();

return true;

}

else

{

return false;

}

}

#endif

bool is_locked_by_this_thread() const

{

return this_thread::get_id() == id_;

}

bool is_locked() const

{

return ! (thread::id() == id_);

}

thread::id get_id() const

{

return id_;

}

// todo add the shared and upgrade mutex functions