Added unit-tests

src/ticked_async_executor.rs

@@ -255,5 +255,48 @@ mod tests {
  let elapsed = now.elapsed();
  println!("Elapsed: {:?}", elapsed);
  println!("Total: {:?}", instances);
+
+ // Test Timer cancellation
+ let timer = executor.create_timer();
+ executor
+ .spawn("ThreadedFuture", async move {
+ timer.sleep_for(1000.0).await;
+ })
+ .detach();
+
+ let timer = executor.create_timer();
+ executor
+ .spawn_local("LocalFuture", async move {
+ timer.sleep_for(1000.0).await;
+ })
+ .detach();
+
+ let mut tick_event = executor.tick_channel();
+ executor
+ .spawn("ThreadedTickFuture", async move {
+ loop {
+ let _r = tick_event.changed().await;
+ if _r.is_err() {
+ break;
+ }
+ }
+ })
+ .detach();
+
+ let mut tick_event = executor.tick_channel();
+ executor
+ .spawn_local("LocalTickFuture", async move {
+ loop {
+ let _r = tick_event.changed().await;
+ if _r.is_err() {
+ break;
+ }
+ }
+ })
+ .detach();
+
+ executor.tick(DELTA);
+ assert_eq!(executor.num_tasks(), 4);
+ drop(executor);
  }
 }

src/ticked_timer.rs

@@ -7,6 +7,8 @@ impl TickedTimer {
  loop {
  let _r = self.tick_recv.changed().await;
  if _r.is_err() {
+ // This means that the executor supplying the delta channel has shutdown
+ // We must stop waiting gracefully
  break;
  }
  let current_dt = *self.tick_recv.borrow_and_update();