boost/thread
2
0
Fork 0
mirror of https://github.com/boostorg/thread.git synced 2026-01-30 20:32:10 +00:00
Code Issues Projects Releases Wiki Activity

manage with 12958.

Browse Source
This commit is contained in:
Vicente J. Botet Escriba
2017-04-29 16:12:35 +02:00
parent da83662e1a
commit 51b367df53
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
include/boost/thread/concurrent_queues/sync_bounded_queue.hpp
View File

@@ -484,7 +484,9 @@ namespace concurrent
queue_op_status sync_bounded_queue<ValueType>::wait_pull_front(ValueType& elem, unique_lock<mutex>& lk)
{
if (empty(lk) && closed(lk)) {return queue_op_status::closed;}
wait_until_not_empty(lk);
bool is_closed = false;
wait_until_not_empty(lk, is_closed);
if (is_closed) {return queue_op_status::closed;}
pull_front(elem, lk);
return queue_op_status::success;
}