mirror/RetroArch
1
0
Fork 0
mirror of https://github.com/libretro/RetroArch synced 2025-04-16 08:43:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

[LIBNX] Threading; Use a ThreadCoreMask and let the system schedule it.

Browse Source
This commit is contained in:
M4xw 2018-09-25 23:50:37 +02:00
parent 95974f9f3a
commit 72ed1c0b82
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
libretro-common/rthreads/switch_pthread.h
View File

@ -66,18 +66,27 @@ static uint32_t threadCounter = 1;
int pthread_create(pthread_t *thread, const pthread_attr_t *attr, void *(*start_routine)(void *), void *arg) int pthread_create(pthread_t *thread, const pthread_attr_t *attr, void *(*start_routine)(void *), void *arg)
{ {
u32 prio = 0; u32 prio = 0;
u64 core_mask = 0;
Thread new_switch_thread; Thread new_switch_thread;
svcGetThreadPriority(&prio, CUR_THREAD_HANDLE); svcGetThreadPriority(&prio, CUR_THREAD_HANDLE);
svcGetInfo(&core_mask, 0, CUR_PROCESS_HANDLE, 0);
// Launch threads on Core 1 // Launch threads on Core 1
int rc = threadCreate(&new_switch_thread, (void (*)(void *))start_routine, arg, STACKSIZE, prio - 1, 1); int rc = threadCreate(&new_switch_thread, (void (*)(void *))start_routine, arg, STACKSIZE, prio - 1, -2);
if (R_FAILED(rc)) if (R_FAILED(rc))
{ {
return EAGAIN; return EAGAIN;
} }
rc = svcSetThreadCoreMask(new_switch_thread.handle, -1, core_mask);
if (R_FAILED(rc))
{
return -1;
}
printf("[Threading]: Starting Thread(#%i)\n", threadCounter); printf("[Threading]: Starting Thread(#%i)\n", threadCounter);
if (R_FAILED(threadStart(&new_switch_thread))) if (R_FAILED(threadStart(&new_switch_thread)))
{ {