add multihreaded test direct draw on main surfacemultithreading

1 files changed, 72 insertions, 0 deletions

diff --git a/tests/multithreading/multithreaded2.c b/tests/multithreading/multithreaded2.c
new file mode 100644
index 0000000..ab55761
--- /dev/null
+++ b/tests/multithreading/multithreaded2.c
@@ -0,0 +1,72 @@
+#include "test.h"
+#include "tinycthread.h"
+
+#define THREAD_COUNT 8
+
+
+static int finishedThreadCount = 0;
+static mtx_t* pmutex;
+
+void drawRandomRect (VkvgContext ctx, float s) {
+	float w = (float)test_width;
+	float h = (float)test_height;
+	randomize_color(ctx);
+
+	float x = truncf(w*rndf());
+	float y = truncf(h*rndf());
+
+	vkvg_rectangle(ctx, x, y, s, s);
+}
+void _before_submit (void* data) {
+	mtx_lock((mtx_t*)data);
+}
+void _after_submit (void* data) {
+	mtx_unlock((mtx_t*)data);
+}
+
+int drawRectsThread () {
+	VkvgContext ctx = vkvg_create(surf);
+	for (uint32_t i=0; i<test_size; i++) {
+		drawRandomRect(ctx, 14.0f);
+		vkvg_fill (ctx);
+	}
+	vkvg_destroy(ctx);
+	mtx_lock(pmutex);
+	finishedThreadCount++;
+	mtx_unlock(pmutex);
+	return 0;
+}
+void fixedSizeRects(){
+	mtx_t gQMutex, mutex;
+	mtx_t* pgQMutex = &gQMutex;
+	pmutex = &mutex;
+
+	mtx_init (pgQMutex, mtx_plain);
+	vkvg_device_set_queue_guards (device, _before_submit, _after_submit, pgQMutex);
+
+	thrd_t threads[THREAD_COUNT];
+
+	finishedThreadCount = 0;
+	mtx_init (pmutex, mtx_plain);
+	for (uint32_t i=0; i<THREAD_COUNT; i++) {
+		thrd_create (&threads[i], drawRectsThread, NULL);
+	}
+
+	const struct timespec ts = {1,0};
+	while (finishedThreadCount < THREAD_COUNT)
+		thrd_sleep(&ts, NULL);
+
+	mtx_lock(pmutex);
+	mtx_unlock(pmutex);
+	mtx_destroy (pmutex);
+	pmutex = NULL;
+
+	vkvg_device_set_queue_guards (device, NULL, NULL, NULL);
+	mtx_destroy (pgQMutex);
+	pgQMutex = NULL;
+}
+
+int main(int argc, char *argv[]) {
+	PERFORM_TEST (fixedSizeRects, argc, argv);
+	return 0;
+}