fabi/Xenia-Canary
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Swapping.

Browse Source
This commit is contained in:
Ben Vanik
2014-12-24 22:35:03 -08:00
parent fa0dfa4dce
commit f438ae1bfd
11 changed files with 380 additions and 127 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/poly/ui/win32/win32_loop.cc
View File

@@ -33,6 +33,10 @@ Win32Loop::Win32Loop() : thread_id_(0) {
poly::threading::set_name("Win32 Loop");
thread_id_ = GetCurrentThreadId();
// Make a Win32 call to enable the thread queue.
MSG msg;
PeekMessage(&msg, NULL, WM_USER, WM_USER, PM_NOREMOVE);
init_fence.Signal();
ThreadMain();
@@ -68,9 +72,11 @@ void Win32Loop::ThreadMain() {
void Win32Loop::Post(std::function<void()> fn) {
assert_true(thread_id_ != 0);
PostThreadMessage(thread_id_, kWmWin32LoopPost,
reinterpret_cast<WPARAM>(this),
reinterpret_cast<LPARAM>(new PostedFn(std::move(fn))));
if (!PostThreadMessage(
thread_id_, kWmWin32LoopPost, reinterpret_cast<WPARAM>(this),
reinterpret_cast<LPARAM>(new PostedFn(std::move(fn))))) {
assert_always("Unable to post message to thread queue");
}
}
void Win32Loop::Quit() {
@@ -79,9 +85,7 @@ void Win32Loop::Quit() {
reinterpret_cast<WPARAM>(this), 0);
}
void Win32Loop::AwaitQuit() {
quit_fence_.Wait();
}
void Win32Loop::AwaitQuit() { quit_fence_.Wait(); }
} // namespace win32
} // namespace ui