Clean up before returning
This commit is contained in:
parent
eb42ebb528
commit
4ce3775630
1 changed files with 5 additions and 1 deletions
|
|
@ -61,7 +61,11 @@ namespace fc {
|
||||||
}
|
}
|
||||||
_enqueue_thread();
|
_enqueue_thread();
|
||||||
// Need to check _ready again to avoid a race condition.
|
// Need to check _ready again to avoid a race condition.
|
||||||
if( _ready.load() ) return _wait_until( timeout_us ); // this will simply return or throw _exceptp
|
if( _ready.load() )
|
||||||
|
{
|
||||||
|
_dequeue_thread();
|
||||||
|
return _wait_until( timeout_us ); // this will simply return or throw _exceptp
|
||||||
|
}
|
||||||
|
|
||||||
std::exception_ptr e;
|
std::exception_ptr e;
|
||||||
//
|
//
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue