pub fn task_polled(&mut self, id: usize, complete: bool, tasks_pending: usize) {
        self.polls += 1;
        let new_local_max = cmp::max(self.tasks_pending_max, tasks_pending);
        if new_local_max > self.tasks_pending_max {
            let prev_upstream_max =
                self.collector.tasks_pending_max.fetch_max(new_local_max, Ordering::Relaxed);
            self.tasks_pending_max = cmp::max(new_local_max, prev_upstream_max);
        }
        if complete {
            self.collector.task_completed(id);
        }
    }
/// Called after a task was polled. If the task completed, `complete`
/// should be true. `pending_tasks` is the observed size of the pending task
/// queue (excluding the currently polled task).
Called after a task was polled. If the task completed, `complete`
should be true. `pending_tasks` is the observed size of the pending task
queue (excluding the currently polled task).
Called after a task was polled . If the task completed ` complete ` should be true . ` pending_tasks ` is the observed size of the pending task queue ( excluding the currently polled task ) .
pub fn task_polled(&mut self, id: usize, complete: bool, tasks_pending: usize) {
        self.polls += 1;
        let new_local_max = cmp::max(self.tasks_pending_max, tasks_pending);
        if new_local_max > self.tasks_pending_max {
            let prev_upstream_max =
                self.collector.tasks_pending_max.fetch_max(new_local_max, Ordering::Relaxed);
            self.tasks_pending_max = cmp::max(new_local_max, prev_upstream_max);
        }
        if complete {
            self.collector.task_completed(id);
        }
    }
pub fn task_polled ( & mut self , id : usize , complete : bool , tasks_pending : usize ) { self . polls += 1 ; let new_local_max = cmp :: max ( self . tasks_pending_max , tasks_pending ) ; if new_local_max > self . tasks_pending_max { let prev_upstream_max = self . collector . tasks_pending_max . fetch_max ( new_local_max , Ordering :: Relaxed ) ; self . tasks_pending_max = cmp :: max ( new_local_max , prev_upstream_max ) ; } if complete { self . collector . task_completed ( id ) ; } }
Called after a task was polled.
Called after a task was polled .
&mut self
id
usize
complete
bool
tasks_pending
usize
&mut self
id
usize
complete
bool
tasks_pending
usize