mika/libnx
1
0
Fork 0
mirror of https://github.com/switchbrew/libnx.git synced 2025-08-07 08:39:24 +02:00
Code Issues Packages Projects Releases Wiki Activity

C11 threads: enable preemptive scheduler and load balancing

Browse Source
This commit is contained in:
fincs 2018-08-06 17:59:51 +02:00
parent 9fa3873fc9
commit f3b530cea3
1 changed files with 23 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
nx/source/runtime/c11-threads.c
View File

@ -192,6 +192,11 @@ int thrd_create(thrd_t *thr, thrd_start_t func, void *arg)
Result rc; Result rc;
*thr = NULL; *thr = NULL;
u64 core_mask = 0;
rc = svcGetInfo(&core_mask, 0, CUR_PROCESS_HANDLE, 0);
if (R_FAILED(rc))
return thrd_error;
__thrd_t* t = (__thrd_t*)malloc(sizeof(__thrd_t)); __thrd_t* t = (__thrd_t*)malloc(sizeof(__thrd_t));
if (!t) if (!t)
return thrd_nomem; return thrd_nomem;
@ -203,18 +208,17 @@ int thrd_create(thrd_t *thr, thrd_start_t func, void *arg)
mtx_init(&info.mutex, mtx_plain); mtx_init(&info.mutex, mtx_plain);
cnd_init(&info.cond); cnd_init(&info.cond);
rc = threadCreate(&t->thr, __thrd_entry, &info, 128*1024, 0x2C, -2); rc = threadCreate(&t->thr, __thrd_entry, &info, 128*1024, 0x3B, -2);
if (R_FAILED(rc)) { if (R_FAILED(rc))
free(t); goto _error1;
return thrd_error;
} rc = svcSetThreadCoreMask(t->thr.handle, -1, core_mask);
if (R_FAILED(rc))
goto _error2;
rc = threadStart(&t->thr); rc = threadStart(&t->thr);
if (R_FAILED(rc)) { if (R_FAILED(rc))
threadClose(&t->thr); goto _error2;
free(t);
return thrd_error;
}
mtx_lock(&info.mutex); mtx_lock(&info.mutex);
while (!info.thread_started) while (!info.thread_started)
@ -223,6 +227,12 @@ int thrd_create(thrd_t *thr, thrd_start_t func, void *arg)
*thr = t; *thr = t;
return thrd_success; return thrd_success;
_error2:
threadClose(&t->thr);
_error1:
free(t);
return thrd_error;
} }
thrd_t thrd_current(void) thrd_t thrd_current(void)
@ -256,7 +266,9 @@ int thrd_join(thrd_t thr, int *res)
if (R_FAILED(rc)) if (R_FAILED(rc))
return thrd_error; return thrd_error;
if (res)
*res = thr->rc; *res = thr->rc;
rc = threadClose(&thr->thr); rc = threadClose(&thr->thr);
free(thr); free(thr);