@@ -11,7 +11,7 @@ use std::sync::atomic::{self, AtomicUsize, Ordering};
11
11
use std:: sync:: Arc ;
12
12
use std:: task:: { Context , Poll } ;
13
13
14
- use crossbeam_utils:: { Backoff , CachePadded } ;
14
+ use crossbeam_utils:: Backoff ;
15
15
16
16
use crate :: stream:: Stream ;
17
17
use crate :: sync:: WakerSet ;
@@ -577,7 +577,7 @@ struct Channel<T> {
577
577
/// represent the lap. The mark bit in the head is always zero.
578
578
///
579
579
/// Messages are popped from the head of the channel.
580
- head : CachePadded < AtomicUsize > ,
580
+ head : AtomicUsize ,
581
581
582
582
/// The tail of the channel.
583
583
///
@@ -586,7 +586,7 @@ struct Channel<T> {
586
586
/// represent the lap. The mark bit indicates that the channel is disconnected.
587
587
///
588
588
/// Messages are pushed into the tail of the channel.
589
- tail : CachePadded < AtomicUsize > ,
589
+ tail : AtomicUsize ,
590
590
591
591
/// The buffer holding slots.
592
592
buffer : * mut Slot < T > ,
@@ -660,8 +660,8 @@ impl<T> Channel<T> {
660
660
cap,
661
661
one_lap,
662
662
mark_bit,
663
- head : CachePadded :: new ( AtomicUsize :: new ( head) ) ,
664
- tail : CachePadded :: new ( AtomicUsize :: new ( tail) ) ,
663
+ head : AtomicUsize :: new ( head) ,
664
+ tail : AtomicUsize :: new ( tail) ,
665
665
send_wakers : WakerSet :: new ( ) ,
666
666
recv_wakers : WakerSet :: new ( ) ,
667
667
stream_wakers : WakerSet :: new ( ) ,
0 commit comments