File tree Expand file tree Collapse file tree 1 file changed +4
-9
lines changed
tokio/src/runtime/scheduler/multi_thread Expand file tree Collapse file tree 1 file changed +4
-9
lines changed Original file line number Diff line number Diff line change @@ -391,12 +391,15 @@ impl<T> Local<T> {
391
391
}
392
392
393
393
impl < T > Steal < T > {
394
- fn len ( & self ) -> usize {
394
+ /// Returns the number of entries in the queue
395
+ pub ( crate ) fn len ( & self ) -> usize {
395
396
let ( _, head) = unpack ( self . 0 . head . load ( Acquire ) ) ;
396
397
let tail = self . 0 . tail . load ( Acquire ) ;
397
398
len ( head, tail)
398
399
}
399
400
401
+ /// Return true if the queue is empty,
402
+ /// false if there are any entries in the queue
400
403
pub ( crate ) fn is_empty ( & self ) -> bool {
401
404
self . len ( ) == 0
402
405
}
@@ -556,14 +559,6 @@ impl<T> Steal<T> {
556
559
}
557
560
}
558
561
559
- cfg_unstable_metrics ! {
560
- impl <T > Steal <T > {
561
- pub ( crate ) fn len( & self ) -> usize {
562
- self . 0 . len( ) as _
563
- }
564
- }
565
- }
566
-
567
562
impl < T > Clone for Steal < T > {
568
563
fn clone ( & self ) -> Steal < T > {
569
564
Steal ( self . 0 . clone ( ) )
You can’t perform that action at this time.
0 commit comments