milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix(db): fix env compile error 

Former-commit-id: 683cb59254dfec9cd6a2d93270cde064a4222779
pull/191/head
Xu Peng 2019-04-15 13:54:10 +08:00 committed by xj.lin
parent 28e42d0ee5
commit e6b0c5a099
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
cpp/src/db/env.cpp
View File

@ -1,16 +1,15 @@
#include <assert.h>
#include "env.h"
namespace zilliz {
namespace vecwise {
namespace engine {
Env::Env()
: _bg_work_cv(&_bg_work_mutex),
_bg_work_started(false) {
Env::Env() : _bg_work_started(false) {
}
void Env::schedule(void (*function_)(void* arg_), void* arg_) {
std::lock_guard<std::mutex> lock;
std::unique_lock<std::mutex> lock(_bg_work_mutex);
if (!_bg_work_started) {
_bg_work_started = true;
@ -27,9 +26,9 @@ void Env::schedule(void (*function_)(void* arg_), void* arg_) {
void Env::backgroud_thread_main() {
while (true) {
std::lock_guard<std::mutex> lock;
std::unique_lock<std::mutex> lock(_bg_work_mutex);
while (_bg_work_queue.empty()) {
_bg_work_cv.wait();
_bg_work_cv.wait(lock);
}
assert(!_bg_work_queue.empty());