coffee/cpp-ipc
1
0
Fork 0
mirror of https://github.com/mutouyun/cpp-ipc.git synced 2025-12-06 16:56:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

adjust ipc::sleep

Browse Source
This commit is contained in:
mutouyun 2019-01-07 15:26:51 +08:00
parent 0dfbfd3fbf
commit 7813e20a5b
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
include/circ_elem_array.h
View File

@ -134,7 +134,7 @@ struct prod_cons<relat::multi, relat::multi, trans::unicast>
if (ct_.compare_exchange_weak(cur_ct, nxt_ct, std::memory_order_relaxed)) { if (ct_.compare_exchange_weak(cur_ct, nxt_ct, std::memory_order_relaxed)) {
break; break;
} }
ipc::sleep<8192>(k); ipc::sleep(k);
} }
std::forward<F>(f)(elem_start + detail::index_of(cur_ct)); std::forward<F>(f)(elem_start + detail::index_of(cur_ct));
for (unsigned k = 0;;) { for (unsigned k = 0;;) {
@ -142,7 +142,7 @@ struct prod_cons<relat::multi, relat::multi, trans::unicast>
if (wt_.compare_exchange_weak(exp_wt, nxt_ct, std::memory_order_release)) { if (wt_.compare_exchange_weak(exp_wt, nxt_ct, std::memory_order_release)) {
break; break;
} }
ipc::sleep<8192>(k); ipc::sleep(k);
} }
return true; return true;
} }
@ -177,7 +177,7 @@ struct prod_cons<relat::single, relat::multi, trans::broadcast> {
expected, static_cast<rc_t>(conn_cnt), std::memory_order_relaxed)) { expected, static_cast<rc_t>(conn_cnt), std::memory_order_relaxed)) {
break; break;
} }
ipc::sleep<8192>(k); ipc::sleep(k);
conn_cnt = elems->conn_count(); // acquire conn_cnt = elems->conn_count(); // acquire
if (conn_cnt == 0) return false; if (conn_cnt == 0) return false;
} }

2
include/rw_lock.h
View File

@ -57,7 +57,7 @@
namespace ipc { namespace ipc {
template <std::size_t N = 4096, typename K> template <std::size_t N = 8192, typename K>
inline void sleep(K& k) noexcept { inline void sleep(K& k) noexcept {
if (k < static_cast<K>(N)) { if (k < static_cast<K>(N)) {
std::this_thread::yield(); std::this_thread::yield();