diff options
Diffstat (limited to 'tests/multithreading')
| -rw-r--r-- | tests/multithreading/multithreaded.c | 19 |
1 files changed, 12 insertions, 7 deletions
diff --git a/tests/multithreading/multithreaded.c b/tests/multithreading/multithreaded.c index cc4aa0a..2b2afc9 100644 --- a/tests/multithreading/multithreaded.c +++ b/tests/multithreading/multithreaded.c @@ -1,7 +1,7 @@ #include "test.h" #include "tinycthread.h" -#define THREAD_COUNT 2 +#define THREAD_COUNT 8 static int finishedThreadCount = 0; @@ -19,16 +19,14 @@ void drawRandomRect (VkvgContext ctx, float s) { } void _before_submit (void* data) { mtx_lock((mtx_t*)data); + printf("sumbit 0x%lx\n", thrd_current()); } void _after_submit (void* data) { + printf("release 0x%lx\n", thrd_current()); mtx_unlock((mtx_t*)data); } int drawRectsThread () { - mtx_t gQMutex; - mtx_init (&gQMutex, mtx_plain); - vkvg_device_set_queue_guards (device, _before_submit, _after_submit, &gQMutex); - VkvgSurface s = vkvg_surface_create(device, test_width, test_height); VkvgContext ctx = vkvg_create(s); for (uint32_t i=0; i<test_size; i++) { @@ -49,12 +47,15 @@ int drawRectsThread () { mtx_unlock(&mutex); vkvg_surface_destroy (s); - vkvg_device_set_queue_guards (device, NULL, NULL, NULL); - mtx_destroy (&gQMutex); return 0; } void fixedSizeRects(){ + printf("==>main 0x%lx\n", thrd_current()); + mtx_t gQMutex; + mtx_init (&gQMutex, mtx_plain); + vkvg_device_set_queue_guards (device, _before_submit, _after_submit, &gQMutex); thrd_t threads[THREAD_COUNT]; + finishedThreadCount = 0; mtx_init (&mutex,mtx_plain); for (uint32_t i=0; i<THREAD_COUNT; i++) { @@ -66,6 +67,10 @@ void fixedSizeRects(){ thrd_sleep(&ts, NULL); mtx_destroy(&mutex); + + vkvg_device_set_queue_guards (device, NULL, NULL, NULL); + mtx_destroy (&gQMutex); + printf("------- 0x%lx\n", thrd_current()); } int main(int argc, char *argv[]) { |