Merge pull request #13467 from JosJuice/profiler-thread-safety

Common: Make Profiler thread safe
This commit is contained in:
JosJuice 2025-04-21 20:19:47 +02:00 committed by GitHub
commit c0c180bdc2
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 25 additions and 18 deletions

View file

@ -29,10 +29,8 @@ std::string Profiler::s_lazy_result;
int Profiler::s_lazy_delay = 0; int Profiler::s_lazy_delay = 0;
Profiler::Profiler(const std::string& name) Profiler::Profiler(const std::string& name)
: m_name(name), m_usecs(0), m_usecs_min(UINT64_MAX), m_usecs_max(0), m_usecs_quad(0), : m_name(name), m_usecs(0), m_usecs_min(UINT64_MAX), m_usecs_max(0), m_usecs_quad(0), m_calls(0)
m_calls(0), m_depth(0)
{ {
m_time = Common::Timer::NowUs();
s_max_length = std::max<u32>(s_max_length, u32(m_name.length())); s_max_length = std::max<u32>(s_max_length, u32(m_name.length()));
std::lock_guard<std::mutex> lk(s_mutex); std::lock_guard<std::mutex> lk(s_mutex);
@ -97,22 +95,23 @@ std::string Profiler::ToString()
return s_lazy_result; return s_lazy_result;
} }
void Profiler::Start() void Profiler::Start(u64* time, int* depth)
{ {
if (!m_depth++) if ((*depth)++ == 0)
{ {
m_time = Common::Timer::NowUs(); *time = Common::Timer::NowUs();
} }
} }
void Profiler::Stop() void Profiler::Stop(u64* time, int* depth)
{ {
if (!--m_depth) if (--(*depth) == 0)
{ {
u64 end = Common::Timer::NowUs(); u64 end = Common::Timer::NowUs();
u64 diff = end - m_time; u64 diff = end - *time;
std::lock_guard lk(m_mutex);
m_usecs += diff; m_usecs += diff;
m_usecs_min = std::min(m_usecs_min, diff); m_usecs_min = std::min(m_usecs_min, diff);
m_usecs_max = std::max(m_usecs_max, diff); m_usecs_max = std::max(m_usecs_max, diff);
@ -123,6 +122,8 @@ void Profiler::Stop()
std::string Profiler::Read() std::string Profiler::Read()
{ {
std::lock_guard lk(m_mutex);
double avg = 0; double avg = 0;
double stdev = 0; double stdev = 0;
double time_rel = 0; double time_rel = 0;

View file

@ -19,8 +19,8 @@ public:
static std::string ToString(); static std::string ToString();
void Start(); void Start(u64* time, int* depth);
void Stop(); void Stop(u64* time, int* depth);
std::string Read(); std::string Read();
bool operator<(const Profiler& b) const; bool operator<(const Profiler& b) const;
@ -35,28 +35,34 @@ private:
static std::string s_lazy_result; static std::string s_lazy_result;
static int s_lazy_delay; static int s_lazy_delay;
std::mutex m_mutex;
std::string m_name; std::string m_name;
u64 m_usecs; u64 m_usecs;
u64 m_usecs_min; u64 m_usecs_min;
u64 m_usecs_max; u64 m_usecs_max;
u64 m_usecs_quad; u64 m_usecs_quad;
u64 m_calls; u64 m_calls;
u64 m_time;
int m_depth;
}; };
class ProfilerExecuter class ProfilerExecuter
{ {
public: public:
ProfilerExecuter(Profiler* _p) : m_p(_p) { m_p->Start(); } ProfilerExecuter(Profiler* profiler, u64* time, int* depth)
~ProfilerExecuter() { m_p->Stop(); } : m_profiler(profiler), m_time(time), m_depth(depth)
{
m_profiler->Start(m_time, m_depth);
}
~ProfilerExecuter() { m_profiler->Stop(m_time, m_depth); }
private: private:
Profiler* m_p; Profiler* m_profiler;
u64* m_time;
int* m_depth;
}; };
} // namespace Common } // namespace Common
// Warning: This profiler isn't thread safe. Only profile functions which doesn't run simultaneously
#define PROFILE(name) \ #define PROFILE(name) \
static Common::Profiler prof_gen(name); \ static Common::Profiler prof_gen(name); \
Common::ProfilerExecuter prof_e(&prof_gen); static thread_local u64 prof_time; \
static thread_local int prof_depth; \
Common::ProfilerExecuter prof_e(&prof_gen, &prof_time, &prof_depth);