v1.0.0-rc.60
This commit is contained in:
@@ -167,6 +167,7 @@ std::optional<size_t> NeuralNetInferenceClient::GetFreeNode() {
|
||||
}
|
||||
return {};
|
||||
}
|
||||
|
||||
std::optional<size_t> NeuralNetInferenceClient::AcquireNode() {
|
||||
std::unique_lock ul(m);
|
||||
|
||||
@@ -179,9 +180,12 @@ std::optional<size_t> NeuralNetInferenceClient::AcquireNode() {
|
||||
|
||||
// No free node available, wait for one with a timeout
|
||||
c.wait_for(ul, std::chrono::milliseconds(200),
|
||||
[this]() { return GetFreeNode().has_value(); });
|
||||
[this, &ret]() {
|
||||
ret = GetFreeNode();
|
||||
return ret.has_value();
|
||||
});
|
||||
|
||||
return GetFreeNode();
|
||||
return ret;
|
||||
}
|
||||
|
||||
void NeuralNetInferenceClient::ReturnNode(size_t node) {
|
||||
|
||||
Reference in New Issue
Block a user