mirror of
https://github.com/LadybirdBrowser/ladybird.git
synced 2024-09-20 01:37:39 +03:00
LibThreading: Add ConditionVariable wrapper
ConditionVariable is a thin wrapper over the pthread_cond_* APIs, just as Mutex is a wrapper over pthread_mutex. Because ConditionVariable might want to wait on a high-level Mutex, it needs to be friends with it.
This commit is contained in:
parent
bd17da9f9e
commit
c7104e7512
Notes:
sideshowbarker
2024-07-18 04:04:46 +09:00
Author: https://github.com/kleinesfilmroellchen Commit: https://github.com/SerenityOS/serenity/commit/c7104e75126 Pull-request: https://github.com/SerenityOS/serenity/pull/9610 Reviewed-by: https://github.com/Hendiadyoin1 Reviewed-by: https://github.com/awesomekling Reviewed-by: https://github.com/bugaevc Reviewed-by: https://github.com/joebentley Reviewed-by: https://github.com/nooga Reviewed-by: https://github.com/sunverwerth
64
Userland/Libraries/LibThreading/ConditionVariable.h
Normal file
64
Userland/Libraries/LibThreading/ConditionVariable.h
Normal file
@ -0,0 +1,64 @@
|
||||
/*
|
||||
* Copyright (c) 2021, kleines Filmröllchen <malu.bertsch@gmail.com>.
|
||||
*
|
||||
* 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;
|
||||
};
|
||||
|
||||
}
|
@ -13,6 +13,8 @@
|
||||
namespace Threading {
|
||||
|
||||
class Mutex {
|
||||
friend class ConditionVariable;
|
||||
|
||||
public:
|
||||
Mutex()
|
||||
{
|
||||
|
Loading…
Reference in New Issue
Block a user