blob: f4f5b2b5336f27a6eb3042d1847e73e247cc3b9b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
/*
* Semaphore
* by Pierre Gaston (http://p9as.blogspot.com/2012/06/c11-semaphores.html)
* modified by Joel Low for Botan
*
*/
#include <botan/internal/semaphore.h>
namespace Botan {
void Semaphore::release(size_t n)
{
for(size_t i = 0; i != n; ++i)
{
std::lock_guard<std::mutex> lock(m_mutex);
++m_value;
if(m_value <= 0)
{
++m_wakeups;
m_cond.notify_one();
}
}
}
void Semaphore::acquire()
{
std::unique_lock<std::mutex> lock(m_mutex);
--m_value;
if(m_value < 0)
{
m_cond.wait(lock, [this] { return m_wakeups > 0; });
--m_wakeups;
}
}
}
|
