admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-01-01 00:15:30 +08:00
Code Issues Packages Projects Releases Wiki Activity

format

Browse Source 
Former-commit-id: cbc8d328bc00325658a17eb4c4198d71d185acd7
This commit is contained in:
wxyu 2019-10-13 17:54:48 +08:00
parent f88b679877
commit 3248d30139
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cpp/src/scheduler/resource/Resource.cpp
View File

@ -133,9 +133,7 @@ void
Resource::loader_function() {
while (running_) {
std::unique_lock<std::mutex> lock(load_mutex_);
load_cv_.wait(lock, [&] {
return load_flag_;
});
load_cv_.wait(lock, [&] { return load_flag_; });
load_flag_ = false;
lock.unlock();
while (true) {
@ -161,9 +159,7 @@ Resource::executor_function() {
}
while (running_) {
std::unique_lock<std::mutex> lock(exec_mutex_);
exec_cv_.wait(lock, [&] {
return exec_flag_;
});
exec_cv_.wait(lock, [&] { return exec_flag_; });
exec_flag_ = false;
lock.unlock();
while (true) {