a little adjustment

This commit is contained in:
mutouyun 2018-11-26 18:35:49 +08:00
parent e2cdcb24c3
commit 2d86727be1

View File

@ -106,8 +106,9 @@ public:
// check read finished by all consumers
do {
uc_t expected = 0;
std::atomic_thread_fence(std::memory_order_acquire);
if (el->head_.rf_.compare_exchange_weak(
expected, static_cast<uc_t>(conn_count()), std::memory_order_acq_rel)) {
expected, cc_.load(std::memory_order_relaxed), std::memory_order_release)) {
break;
}
std::this_thread::yield();