修复BUG
This commit is contained in:
parent
1bbc4d9186
commit
fa0eaad4f9
|
@ -114,6 +114,7 @@ class safe_queue
|
||||||
std::mutex lock_;
|
std::mutex lock_;
|
||||||
std::vector<TNS> queue_;
|
std::vector<TNS> queue_;
|
||||||
size_t bytes_;
|
size_t bytes_;
|
||||||
|
T empty_;
|
||||||
|
|
||||||
public:
|
public:
|
||||||
safe_queue() : bytes_(0)
|
safe_queue() : bytes_(0)
|
||||||
|
@ -157,6 +158,8 @@ public:
|
||||||
if (first)
|
if (first)
|
||||||
first(t.t);
|
first(t.t);
|
||||||
}
|
}
|
||||||
|
else
|
||||||
|
t.t = empty_;
|
||||||
|
|
||||||
return t.t;
|
return t.t;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue