asonix/background-jobs
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

actix: simply start_in_arbiter

Browse source
This commit is contained in:
Aode (Lion) 2021-10-06 21:12:16 -05:00
parent 1ce008e8c4
commit 1266873f5d
1 changed files with 1 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
jobs-actix/src/lib.rs
View file

@ -216,17 +216,7 @@ where
/// Start the workers in the provided arbiter
pub fn start_in_arbiter(self, arbiter: &Arbiter, queue_handle: QueueHandle) {
for (key, count) in self.queues.into_iter() {
for _ in 0..count {
let key = key.clone();
let processors = self.processors.clone();
let server = queue_handle.inner.clone();
arbiter.spawn_fn(move || {
local_worker(key, processors.cached(), server);
});
}
}
self.start_in_arbiter_handle(&arbiter.handle(), queue_handle)
}
/// Start the workers in the provided arbiter via it's handle