1
0
mirror of https://github.com/RPCS3/rpcs3.git synced 2025-01-26 18:35:18 +00:00

46 lines
988 B
C
Raw Normal View History

2014-12-23 02:31:11 +03:00
#pragma once
2015-11-26 11:06:29 +03:00
using sleep_entry_t = class CPUThread;
using sleep_queue_t = std::deque<std::shared_ptr<sleep_entry_t>>;
static struct defer_sleep_t {} const defer_sleep{};
2015-07-19 04:56:33 +03:00
// automatic object handling a thread entry in the sleep queue
class sleep_queue_entry_t final
2014-12-23 02:31:11 +03:00
{
2015-11-26 11:06:29 +03:00
sleep_entry_t& m_thread;
sleep_queue_t& m_queue;
2014-12-24 19:09:32 +03:00
2015-07-19 04:56:33 +03:00
void add_entry();
void remove_entry();
bool find() const;
2014-12-24 19:09:32 +03:00
public:
2015-07-19 04:56:33 +03:00
// add specified thread to the sleep queue
2015-11-26 11:06:29 +03:00
sleep_queue_entry_t(sleep_entry_t& entry, sleep_queue_t& queue);
2014-12-28 16:15:22 +03:00
2015-07-19 04:56:33 +03:00
// don't add specified thread to the sleep queue
2015-11-26 11:06:29 +03:00
sleep_queue_entry_t(sleep_entry_t& entry, sleep_queue_t& queue, const defer_sleep_t&);
2015-07-19 04:56:33 +03:00
// removes specified thread from the sleep queue if added
~sleep_queue_entry_t();
2015-07-19 04:56:33 +03:00
// add thread to the sleep queue
void enter()
2015-07-19 04:56:33 +03:00
{
add_entry();
}
// remove thread from the sleep queue
void leave()
2015-07-19 04:56:33 +03:00
{
remove_entry();
}
// check whether the thread exists in the sleep queue
explicit operator bool() const
2015-07-19 04:56:33 +03:00
{
return find();
}
2014-12-23 02:31:11 +03:00
};