Lines Matching refs:scheduler
202 enter(self, |scheduler, context| { in block_on()
204 let waker = scheduler.spawner.waker_ref(); in block_on()
211 if scheduler.spawner.was_woken() || !polled { in block_on()
220 let tick = scheduler.tick; in block_on()
221 scheduler.tick = scheduler.tick.wrapping_add(1); in block_on()
224 scheduler.spawner.pop().or_else(|| { in block_on()
239 .or_else(|| scheduler.spawner.pop()) in block_on()
246 scheduler.park.park().expect("failed to park"); in block_on()
279 scheduler in block_on()
290 fn enter<F, R, P>(scheduler: &mut Inner<P>, f: F) -> R in enter()
299 scheduler: &'a mut Inner<P>, in enter() field
305 self.scheduler.tasks = Some(tasks.into_inner()); in enter()
310 let tasks = scheduler.tasks.take().expect("invalid state"); in enter()
314 shared: scheduler.spawner.shared.clone(), in enter()
317 scheduler, in enter()
321 let scheduler = &mut *guard.scheduler; in enter() localVariable
323 CURRENT.set(context, || f(scheduler, context)) in enter()
337 enter(&mut inner, |scheduler, context| { in drop()
355 for entry in scheduler.spawner.shared.queue.lock().drain(..) { in drop()
487 if let Some(scheduler) = self.inner.take() { in drop()
492 lock.replace(scheduler); in drop()