#include "config.h"
#include "Threading.h"
#include "Logging.h"
#include "Page.h"
#include <windows.h>
namespace WebCore {
static HWND threadingWindowHandle = 0;
static UINT threadingFiredMessage = 0;
const LPCWSTR kThreadingWindowClassName = L"ThreadingWindowClass";
static bool processingCustomThreadingMessage = false;
Mutex functionQueueMutex;
Vector<void(*)()> functionQueue;
static void callFunctionsOnMainThread()
{
Vector<void(*)()> queueCopy;
{
MutexLocker locker(functionQueueMutex);
queueCopy.swap(functionQueue);
}
LOG(Threading, "Calling %u functions on the main thread", queueCopy.size());
for (unsigned i = 0; i < queueCopy.size(); ++i)
queueCopy[i]();
}
LRESULT CALLBACK ThreadingWindowWndProc(HWND hWnd, UINT message, WPARAM wParam, LPARAM lParam)
{
if (message == threadingFiredMessage) {
processingCustomThreadingMessage = true;
callFunctionsOnMainThread();
processingCustomThreadingMessage = false;
} else
return DefWindowProc(hWnd, message, wParam, lParam);
return 0;
}
void initializeThreading()
{
if (threadingWindowHandle)
return;
WNDCLASSEX wcex;
memset(&wcex, 0, sizeof(WNDCLASSEX));
wcex.cbSize = sizeof(WNDCLASSEX);
wcex.lpfnWndProc = ThreadingWindowWndProc;
wcex.hInstance = Page::instanceHandle();
wcex.lpszClassName = kThreadingWindowClassName;
RegisterClassEx(&wcex);
threadingWindowHandle = CreateWindow(kThreadingWindowClassName, 0, 0,
CW_USEDEFAULT, 0, CW_USEDEFAULT, 0, HWND_MESSAGE, 0, Page::instanceHandle(), 0);
threadingFiredMessage = RegisterWindowMessage(L"com.apple.WebKit.MainThreadFired");
}
void callOnMainThread(void(*function)())
{
ASSERT(function);
ASSERT(threadingWindowHandle);
if (processingCustomThreadingMessage)
LOG(Threading, "callOnMainThread() called recursively. Beware of nested PostMessage()s");
{
MutexLocker locker(functionQueueMutex);
functionQueue.append(function);
}
PostMessage(threadingWindowHandle, threadingFiredMessage, 0, 0);
}
}