forked from ROMEO/nexosim
Fix bug introduced during refactoring
This commit is contained in:
parent
d2cfbcfa34
commit
835dd5ea8e
@ -90,6 +90,7 @@ impl PoolManager {
|
|||||||
self.record.increment(first_idle_worker);
|
self.record.increment(first_idle_worker);
|
||||||
self.begin_worker_search();
|
self.begin_worker_search();
|
||||||
self.worker_unparkers[first_idle_worker].unpark();
|
self.worker_unparkers[first_idle_worker].unpark();
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -121,6 +122,7 @@ impl PoolManager {
|
|||||||
self.record.increment(first_idle_worker);
|
self.record.increment(first_idle_worker);
|
||||||
self.begin_worker_search();
|
self.begin_worker_search();
|
||||||
self.worker_unparkers[first_idle_worker].unpark();
|
self.worker_unparkers[first_idle_worker].unpark();
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user