Merge pull request #15 from serprex/master

Replace time with std::time

Cargo.toml

@@ -8,7 +8,6 @@ homepage = "https://github.com/csherratt/pulse"
 
 [dependencies]
 atom = "0.3"
-time = "0.1"
 
 [features]
 default = []

src/lib.rs

@@ -13,18 +13,17 @@
 //   limitations under the License.
 
 extern crate atom;
-extern crate time;
 
 use std::sync::atomic::AtomicUsize;
 use std::thread;
+use std::time::{Duration, Instant};
 use std::mem;
 use std::fmt;
 use std::ops::Deref;
 use std::sync::atomic::Ordering;
 use std::cell::RefCell;
 
 use atom::*;
-use time::precise_time_s;
 use fnbox::FnBox;
 
 pub use select::{Select, SelectMap};
@@ -517,17 +516,17 @@ impl Scheduler for ThreadScheduler {
     }
 
     fn wait_timeout_ms(&self, signal: Signal, ms: u32) -> Result<(), TimeoutError> {
-        let mut now = (precise_time_s() * 1000.) as u64;
-        let end = now + ms as u64;
+        let start = Instant::now();
+        let ms = Duration::from_millis(ms as u64);
 
         loop {
             let id = signal.add_to_waitlist(Waiting::thread());
             if signal.is_pending() {
-                now = (precise_time_s() * 1000.) as u64;
-                if now > end {
+                let elapsed = start.elapsed();
+                if elapsed > ms {
                     return Err(TimeoutError::Timeout);
                 }
-                thread::park_timeout_ms((end - now) as u32);
+                thread::park_timeout(ms - elapsed);
             }
             signal.remove_from_waitlist(id);