boost/log
2
0
Fork 0
mirror of https://github.com/boostorg/log.git synced 2026-02-08 23:02:17 +00:00
Code Issues Projects Releases Wiki Activity

Changed adaptive_mutex to use pthread_mutex_t. On systems that support it (Linux, FreeBSD, OpenBSD) PTHREAD_MUTEX_ADAPTIVE_NP is used, otherwise the default mutex type. This greatly imporoves performance in case of heavy thread contention: 100 threads - x2.7 records per second, 1000 threads - x4. Less contended cases are mostly unaffected.

Browse Source
This commit is contained in:
Andrey Semashev
2015-11-15 17:18:48 +03:00
parent 5434177322
commit b5969e5233
3 changed files with 46 additions and 95 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/threadsafe_queue.cpp
View File

@@ -46,7 +46,7 @@ class threadsafe_queue_impl_generic :
{
private:
//! Mutex type to be used
typedef spin_mutex mutex_type;
typedef adaptive_mutex mutex_type;
/*!
* A structure that contains a pointer to the node and the associated mutex.
@@ -116,10 +116,6 @@ public:
}
private:
// Copying and assignment are closed
threadsafe_queue_impl_generic(threadsafe_queue_impl_generic const&);
threadsafe_queue_impl_generic& operator= (threadsafe_queue_impl_generic const&);
BOOST_FORCEINLINE static void set_next(node_base* p, node_base* next)
{
p->next.data[0] = next;
@@ -128,6 +124,10 @@ private:
{
return static_cast< node_base* >(p->next.data[0]);
}
// Copying and assignment are closed
BOOST_DELETED_FUNCTION(threadsafe_queue_impl_generic(threadsafe_queue_impl_generic const&))
BOOST_DELETED_FUNCTION(threadsafe_queue_impl_generic& operator= (threadsafe_queue_impl_generic const&))
};
BOOST_LOG_API threadsafe_queue_impl* threadsafe_queue_impl::create(node_base* first_node)
@@ -138,7 +138,7 @@ BOOST_LOG_API threadsafe_queue_impl* threadsafe_queue_impl::create(node_base* fi
BOOST_LOG_API void* threadsafe_queue_impl::operator new (std::size_t size)
{
void* p = alignment::aligned_alloc(BOOST_LOG_CPU_CACHE_LINE_SIZE, size);
if (!p)
if (BOOST_UNLIKELY(!p))
BOOST_THROW_EXCEPTION(std::bad_alloc());
return p;
}