windows: use the real-time work queue API

Author: eyelash

CMakeLists.txt

@@ -3,7 +3,7 @@ project(libgral)
 
 if(CMAKE_SYSTEM_NAME STREQUAL "Windows")
 	add_library(gral gral_windows.cpp)
-	target_link_libraries(gral d2d1 dwrite windowsapp)
+	target_link_libraries(gral d2d1 dwrite rtworkq windowsapp)
 	target_compile_definitions(gral PUBLIC GRAL_WINDOWS)
 elseif(CMAKE_SYSTEM_NAME STREQUAL "Darwin")
 	find_library(COCOA Cocoa)

gral_windows.cpp

@@ -21,6 +21,7 @@ THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLI
 #include <dwrite.h>
 #include <stdlib.h>
 #include <mmdeviceapi.h>
+#include <rtworkq.h>
 #include <audioclient.h>
 #include <roapi.h>
 #include <windows.foundation.h>
@@ -1507,9 +1508,17 @@ struct gral_audio {
 	HANDLE exit_event;
 };
 
-static DWORD WINAPI audio_thread(LPVOID user_data) {
-	gral_audio *audio = (gral_audio *)user_data;
-	CoInitialize(NULL);
+class AudioCallback: public IRtwqAsyncCallback {
+
+
+};
+
+gral_audio *gral_audio_create(char const *name, void (*callback)(float *buffer, int frames, void *user_data), void *user_data) {
+	gral_audio *audio = new gral_audio();
+	audio->callback = callback;
+	audio->user_data = user_data;
+	//audio->exit_event = CreateEvent(NULL, FALSE, FALSE, NULL);
+	//audio->thread = CreateThread(NULL, 0, &audio_thread, audio, 0, NULL);
 	ComPointer<IMMDeviceEnumerator> device_enumerator;
 	CoCreateInstance(__uuidof(MMDeviceEnumerator), NULL, CLSCTX_ALL, __uuidof(IMMDeviceEnumerator), (void **)&device_enumerator);
 	ComPointer<IMMDevice> device;
@@ -1530,13 +1539,19 @@ static DWORD WINAPI audio_thread(LPVOID user_data) {
 	IAudioRenderClient *render_client;
 	audio_client->GetService(__uuidof(IAudioRenderClient), (void **)&render_client);
 	HANDLE event = CreateEvent(NULL, FALSE, FALSE, NULL);
+	DWORD task_id = 0;
+	DWORD id;
+	RtwqLockSharedWorkQueue(L"Pro Audio", 0, &task_id, &id);
+	ComPointer<IRtwqAsyncResult> async_result;
+	RtwqCreateAsyncResult(NULL, NULL, NULL, &async_result);
+	RtwqPutWaitingWorkItem(event, 1, async_result, NULL);
 	audio_client->SetEventHandle(event);
 	BYTE *buffer;
 	render_client->GetBuffer(buffer_size, &buffer);
 	audio->callback((float *)buffer, buffer_size, audio->user_data);
 	render_client->ReleaseBuffer(buffer_size, 0);
 	audio_client->Start();
-	HANDLE events[] = {event, audio->exit_event};
+	/*HANDLE events[] = {event, audio->exit_event};
 	UINT32 padding;
 	while (WaitForMultipleObjects(2, events, FALSE, INFINITE) != WAIT_OBJECT_0 + 1) {
 		audio_client->GetCurrentPadding(&padding);
@@ -1545,28 +1560,18 @@ static DWORD WINAPI audio_thread(LPVOID user_data) {
 			audio->callback((float *)buffer, buffer_size - padding, audio->user_data);
 			render_client->ReleaseBuffer(buffer_size - padding, 0);
 		}
-	}
+	}*/
 	audio_client->Stop();
 	CloseHandle(event);
 	render_client->Release();
-	CoUninitialize();
-	return 0;
-}
-
-gral_audio *gral_audio_create(char const *name, void (*callback)(float *buffer, int frames, void *user_data), void *user_data) {
-	gral_audio *audio = new gral_audio();
-	audio->callback = callback;
-	audio->user_data = user_data;
-	audio->exit_event = CreateEvent(NULL, FALSE, FALSE, NULL);
-	audio->thread = CreateThread(NULL, 0, &audio_thread, audio, 0, NULL);
 	return audio;
 }
 
 void gral_audio_delete(gral_audio *audio) {
-	SetEvent(audio->exit_event);
+	/*SetEvent(audio->exit_event);
 	WaitForSingleObject(audio->thread, INFINITE);
 	CloseHandle(audio->exit_event);
-	CloseHandle(audio->thread);
+	CloseHandle(audio->thread);*/
 	delete audio;
 }