breeze/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-02-08 01:33:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

Adjust unlock sequence to reduce locking overhead. (#1746)

Browse Source
This commit is contained in:
xiehan
2025-07-02 14:29:57 +08:00
committed by GitHub
parent e6192ee14e
commit e16d4c4cc2
1 changed files with 4 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/kernel/CommScheduler.cc
View File

@@ -144,15 +144,9 @@ CommTarget *CommSchedTarget::acquire(int wait_timeout)
void CommSchedTarget::release()
{
pthread_mutex_t *mutex = &this->mutex;
pthread_mutex_lock(mutex);
pthread_mutex_lock(&this->mutex);
if (this->group)
{
mutex = &this->group->mutex;
pthread_mutex_lock(mutex);
pthread_mutex_unlock(&this->mutex);
}
pthread_mutex_lock(&this->group->mutex);
this->cur_load--;
if (this->wait_cnt > 0)
@@ -165,9 +159,10 @@ void CommSchedTarget::release()
pthread_cond_signal(&this->group->cond);
this->group->heap_adjust(this->index, this->has_idle_conn());
pthread_mutex_unlock(&this->group->mutex);
}
pthread_mutex_unlock(mutex);
pthread_mutex_unlock(&this->mutex);
}
int CommSchedGroup::target_cmp(CommSchedTarget *target1,