berkus
/
actix-net
mirror of https://github.com/fafhrd91/actix-net
1
0
Fork 0
Code Issues Releases Wiki Activity

stop workers in forced shutdown

This commit is contained in:
Ali MJ Al-Nasrawy 2021-12-05 21:15:04 +03:00
parent e0fa4c3ef1
commit a61290f564
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
actix-server/src/server.rs
View File

@ -245,13 +245,15 @@ impl ServerInner {
// stop accept thread // stop accept thread
self.waker_queue.wake(WakerInterest::Stop); self.waker_queue.wake(WakerInterest::Stop);
// send stop signal to workers
let workers_stop = self
.worker_handles
.iter()
.map(|worker| worker.stop(graceful))
.collect::<Vec<_>>();
if graceful { if graceful {
// wait for all workers to shut down // wait for all workers to shut down
let workers_stop = self
.worker_handles
.iter()
.map(|worker| worker.stop(graceful))
.collect::<Vec<_>>();
let _ = join_all(workers_stop).await; let _ = join_all(workers_stop).await;
} }