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

not throw but waiting when size == 0

Browse Source
This commit is contained in:
mutouyun 2018-12-20 17:14:27 +08:00
parent 0429a2c87b
commit b5ae2746a2
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
include/circ_queue.h
View File

@ -7,6 +7,8 @@
#include <algorithm> #include <algorithm>
#include <atomic> #include <atomic>
#include <tuple> #include <tuple>
#include <thread>
#include <chrono>
#include "def.h" #include "def.h"
#include "circ_elem_array.h" #include "circ_elem_array.h"
@ -111,9 +113,8 @@ public:
template <typename F> template <typename F>
static queue* multi_wait_for(F&& upd) { static queue* multi_wait_for(F&& upd) {
while (1) { for (unsigned k = 0;; ++k) {
auto [ques, size] = upd(); auto [ques, size] = upd();
if (size == 0) throw std::invalid_argument { "Invalid size." };
for (std::size_t i = 0; i < static_cast<std::size_t>(size); ++i) { for (std::size_t i = 0; i < static_cast<std::size_t>(size); ++i) {
queue* que = ques[i]; queue* que = ques[i];
if (que == nullptr) continue; if (que == nullptr) continue;
@ -124,7 +125,9 @@ public:
return que; return que;
} }
} }
std::this_thread::yield(); if (k < 1024) std::this_thread::yield();
// yielding coarsening
else std::this_thread::sleep_for(std::chrono::milliseconds(1));
} }
} }