RPCS3/rpcs3
1
0
Fork 0
mirror of https://github.com/RPCS3/rpcs3.git synced 2024-11-22 10:42:36 +01:00
Code Issues Releases Wiki Activity

SPU: Fix "Max SPURS Threads" performance

Browse Source
This commit is contained in:
Elad 2024-10-07 15:32:59 +03:00
parent d51d5ce86d
commit c009215983
1 changed files with 18 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
rpcs3/Emu/Cell/SPUThread.cpp
View File

@ -4897,28 +4897,30 @@ bool spu_thread::process_mfc_cmd()
// Wait for other threads to complete their tasks (temporarily) // Wait for other threads to complete their tasks (temporarily)
u32 max_run = group->max_run; u32 max_run = group->max_run;
u32 prev_running = group->spurs_running.fetch_op([max_run](u32& x) auto [prev_running, ok] = group->spurs_running.fetch_op([max_run, num = group->max_num](u32& x)
{ {
if (x >= max_run) if (x >= max_run && max_run < num)
{ {
x--; x--;
return true; return true;
} }
return false; return false;
}).first; });
if (prev_running == max_run && prev_running != group->max_num) if (prev_running == max_run && ok)
{ {
group->spurs_running.notify_one(); group->spurs_running.notify_one();
if (group->spurs_running == max_run - 1) if (group->spurs_running == max_run - 1)
{ {
spurs_waited = true;
// Try to let another thread slip in and take over execution // Try to let another thread slip in and take over execution
thread_ctrl::wait_for(300); thread_ctrl::wait_for(300);
// Try to quit waiting // Try to quit waiting
prev_running = group->spurs_running.fetch_op([max_run](u32& x) ok = !group->spurs_running.fetch_op([max_run](u32& x)
{ {
if (x < max_run) if (x < max_run)
{ {
@ -4927,17 +4929,22 @@ bool spu_thread::process_mfc_cmd()
} }
return false; return false;
}).first; }).second;
} }
} }
if (prev_running >= max_run) if (ok)
{ {
// Restore state
prev_running--;
const u64 before = get_system_time(); const u64 before = get_system_time();
u64 current = before; u64 current = before;
lv2_obj::prepare_for_sleep(*this); lv2_obj::prepare_for_sleep(*this);
spurs_waited = true;
while (true) while (true)
{ {
if (is_stopped()) if (is_stopped())
@ -4945,7 +4952,10 @@ bool spu_thread::process_mfc_cmd()
break; break;
} }
thread_ctrl::wait_on(group->spurs_running, prev_running, 10000 - (current - before)); if (prev_running >= max_run)
{
thread_ctrl::wait_on(group->spurs_running, prev_running, 10000 - (current - before));
}
max_run = group->max_run; max_run = group->max_run;