Bitcoin Core 30.99.0
P2P Digital Currency
threadinterrupt.cpp
Go to the documentation of this file.
1// Copyright (c) 2009-2010 Satoshi Nakamoto
2// Copyright (c) 2009-2022 The Bitcoin Core developers
3// Distributed under the MIT software license, see the accompanying
4// file COPYING or http://www.opensource.org/licenses/mit-license.php.
5
6#include <util/threadinterrupt.h>
7
8#include <sync.h>
9
11
13{
14 return flag.load(std::memory_order_acquire);
15}
16
17CThreadInterrupt::operator bool() const
18{
19 return interrupted();
20}
21
23{
24 flag.store(false, std::memory_order_release);
25}
26
28{
29 {
30 LOCK(mut);
31 flag.store(true, std::memory_order_release);
32 }
33 cond.notify_all();
34}
35
36bool CThreadInterrupt::sleep_for(Clock::duration rel_time)
37{
38 WAIT_LOCK(mut, lock);
39 return !cond.wait_for(lock, rel_time, [this]() { return flag.load(std::memory_order_acquire); });
40}
virtual void operator()() EXCLUSIVE_LOCKS_REQUIRED(!mut)
Interrupt any sleeps. After this interrupted() will return true.
virtual void reset()
Reset to an non-interrupted state.
std::atomic< bool > flag
virtual bool sleep_for(Clock::duration rel_time) EXCLUSIVE_LOCKS_REQUIRED(!mut)
Sleep for the given duration.
virtual bool interrupted() const
Return true if operator()() has been called.
std::condition_variable cond
#define WAIT_LOCK(cs, name)
Definition: sync.h:265
#define LOCK(cs)
Definition: sync.h:259