Merge pull request #622 from fufesou/fix_deadlock_general_service
fix_deadlock_general_service
This commit is contained in:
commit
223a4f2323
@ -89,7 +89,12 @@ impl<T: Subscriber + From<ConnInner>> Service for ServiceTmpl<T> {
|
|||||||
|
|
||||||
fn join(&self) {
|
fn join(&self) {
|
||||||
self.0.write().unwrap().active = false;
|
self.0.write().unwrap().active = false;
|
||||||
self.0.write().unwrap().handle.take().map(JoinHandle::join);
|
let handle = self.0.write().unwrap().handle.take();
|
||||||
|
if let Some(handle) = handle {
|
||||||
|
if let Err(e) = handle.join() {
|
||||||
|
log::error!("Failed to join thread for service {}, {:?}", self.name(), e);
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user