blob: cf8b63ef250b48259c1aa650887a5c845709ecc3 (
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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
/*
* Copyright (c) 2021, kleines Filmröllchen <filmroellchen@serenityos.org>.
*
* SPDX-License-Identifier: BSD-2-Clause
*/
#pragma once
#include <AK/Function.h>
#include <LibThreading/Mutex.h>
#include <pthread.h>
#include <sys/cdefs.h>
#include <sys/types.h>
namespace Threading {
// A signaling condition variable that wraps over the pthread_cond_* APIs.
class ConditionVariable {
friend class Mutex;
public:
ConditionVariable(Mutex& to_wait_on)
: m_to_wait_on(to_wait_on)
{
auto result = pthread_cond_init(&m_condition, nullptr);
VERIFY(result == 0);
}
ALWAYS_INLINE ~ConditionVariable()
{
auto result = pthread_cond_destroy(&m_condition);
VERIFY(result == 0);
}
// As with pthread APIs, the mutex must be locked or undefined behavior ensues.
ALWAYS_INLINE void wait()
{
auto result = pthread_cond_wait(&m_condition, &m_to_wait_on.m_mutex);
VERIFY(result == 0);
}
ALWAYS_INLINE void wait_while(Function<bool()> condition)
{
while (condition())
wait();
}
// Release at least one of the threads waiting on this variable.
ALWAYS_INLINE void signal()
{
auto result = pthread_cond_signal(&m_condition);
VERIFY(result == 0);
}
// Release all of the threads waiting on this variable.
ALWAYS_INLINE void broadcast()
{
auto result = pthread_cond_broadcast(&m_condition);
VERIFY(result == 0);
}
private:
pthread_cond_t m_condition;
Mutex& m_to_wait_on;
};
}
|
