use drumbeat::sync::runtime::Runtime;

use std::sync::atomic::{AtomicI32, Ordering};
use std::sync::Arc;

#[test]
fn runtime_test() {
  let counter = Arc::new(AtomicI32::new(0));
  for _ in 0..100 {
    let cloned = counter.clone();
    Runtime::submit(move || {
      cloned.fetch_add(1, Ordering::Relaxed);
    });
  }
  while !Runtime::done() {}
  assert_eq!(counter.load(Ordering::Relaxed), 100);
}