Remove unnecessary imports

Author: taiki-e

futures-channel/src/mpsc/mod.rs

@@ -88,7 +88,6 @@ use std::pin::Pin;
 use std::sync::{Arc, Mutex};
 use std::sync::atomic::AtomicUsize;
 use std::sync::atomic::Ordering::SeqCst;
-use std::usize;
 
 use crate::mpsc::queue::Queue;
 
@@ -288,13 +287,13 @@ struct State {
 }
 
 // The `is_open` flag is stored in the left-most bit of `Inner::state`
-const OPEN_MASK: usize = usize::MAX - (usize::MAX >> 1);
+const OPEN_MASK: usize = usize::max_value() - (usize::max_value() >> 1);
 
 // When a new channel is created, it is created in the open state with no
 // pending messages.
 const INIT_STATE: usize = OPEN_MASK;
 
-// The maximum number of messages that a channel can track is `usize::MAX >> 1`
+// The maximum number of messages that a channel can track is `usize::max_value() >> 1`
 const MAX_CAPACITY: usize = !(OPEN_MASK);
 
 // The maximum requested buffer size must be less than the maximum capacity of

futures-channel/src/mpsc/queue.rs

@@ -42,7 +42,6 @@
 //       slightly modified
 
 pub(super) use self::PopResult::*;
-use std::prelude::v1::*;
 
 use std::thread;
 use std::cell::UnsafeCell;

futures-executor/src/enter.rs

@@ -1,4 +1,3 @@
-use std::prelude::v1::*;
 use std::cell::Cell;
 use std::fmt;
 

futures-executor/src/local_pool.rs

@@ -8,7 +8,6 @@ use futures_util::stream::StreamExt;
 use pin_utils::pin_mut;
 use std::cell::{RefCell};
 use std::ops::{Deref, DerefMut};
-use std::prelude::v1::*;
 use std::rc::{Rc, Weak};
 use std::sync::Arc;
 use std::thread::{self, Thread};

futures-executor/src/thread_pool.rs

@@ -4,9 +4,7 @@ use futures_core::future::{Future, FutureObj};
 use futures_core::task::{Context, Poll, Spawn, SpawnError};
 use futures_util::future::FutureExt;
 use futures_util::task::{ArcWake, waker_ref};
-use num_cpus;
 use std::io;
-use std::prelude::v1::*;
 use std::sync::{Arc, Mutex};
 use std::sync::atomic::{AtomicUsize, Ordering};
 use std::sync::mpsc;

futures-io/src/lib.rs

@@ -18,7 +18,6 @@
 #[cfg(feature = "std")]
 mod if_std {
     use futures_core::task::{Context, Poll};
-    use std::boxed::Box;
     use std::cmp;
     use std::io as StdIo;
     use std::ops::DerefMut;

futures-test/src/io/read/interleave_pending.rs

@@ -1,7 +1,6 @@
 use futures_io::{self as io, AsyncBufRead, AsyncRead};
 use pin_utils::{unsafe_pinned, unsafe_unpinned};
 use std::{
-    marker::Unpin,
     pin::Pin,
     task::{Context, Poll},
 };

futures-test/src/io/write/interleave_pending_write.rs

@@ -1,7 +1,6 @@
 use futures_io::{self as io, AsyncWrite};
 use pin_utils::{unsafe_pinned, unsafe_unpinned};
 use std::{
-    marker::Unpin,
     pin::Pin,
     task::{Context, Poll},
 };

futures-test/src/io/write/limited_write.rs

@@ -2,7 +2,6 @@ use futures_io::{self as io, AsyncWrite};
 use pin_utils::{unsafe_pinned, unsafe_unpinned};
 use std::{
     cmp,
-    marker::Unpin,
     pin::Pin,
     task::{Context, Poll},
 };

futures-test/src/stream/interleave_pending.rs

@@ -1,7 +1,6 @@
 use futures_core::stream::Stream;
 use pin_utils::{unsafe_pinned, unsafe_unpinned};
 use std::{
-    marker::Unpin,
     pin::Pin,
     task::{Context, Poll},
 };