From 704ddcf42aa87fd285515149232f45fc6bc98e80 Mon Sep 17 00:00:00 2001 From: Andrew Guschin Date: Wed, 9 Oct 2024 04:54:59 +0400 Subject: remove deps for nir --- graph-checker/src/main.rs | 43 +++++++------------------------------------ 1 file changed, 7 insertions(+), 36 deletions(-) (limited to 'graph-checker/src/main.rs') diff --git a/graph-checker/src/main.rs b/graph-checker/src/main.rs index f738806..215b69e 100644 --- a/graph-checker/src/main.rs +++ b/graph-checker/src/main.rs @@ -1,8 +1,5 @@ -// use std::io::{self, BufRead}; -// use rayon::prelude::*; use sqlx::migrate::MigrateDatabase; -// use std::sync::{Arc, Mutex}; -// use std::time::Instant; +use std::time::Instant; use tokio; mod graph; @@ -27,12 +24,11 @@ async fn main() -> Result<(), sqlx::Error> { .execute(&db) .await; - let gi = GengIterator::new(6); + let gi = GengIterator::new(9); - let mut res = Vec::new(); + let start = Instant::now(); const BATCH_SIZE: usize = 10000; - loop { let graphs = gi.take(BATCH_SIZE); let tasks: Vec<_> = graphs @@ -49,40 +45,15 @@ async fn main() -> Result<(), sqlx::Error> { }) }) .collect(); - let mut part = futures::future::join_all(tasks).await; + let part = futures::future::join_all(tasks).await; if part.len() < BATCH_SIZE { - res.append(&mut part); break; } - res.append(&mut part); } - // let elapsed = start.elapsed(); - // let time = elapsed.as_nanos(); - // let res = res.iter().map(|e| e.as_ref().unwrap()).collect::>(); - println!("len = {}", res.len()); - // println!("Time elapsed: {}s", time as f64 / 1e9); - - // let res: Vec<_> = - // gi.par_bridge().map(compute::dominating_numbers).collect(); - // let res: Vec<_> = gi.map(compute::dominating_numbers).collect(); - - // for pair in &res { - // if let Some(cardinality) = pair.1 { - // println!("{} {:?} {:?}", pair.0, cardinality, pair.2); - // } - // } - - // let start = Instant::now(); - // let res = gi - // .par_bridge() - // .map(compute::apply_theorems) - // .collect::>(); - // - // let elapsed = start.elapsed(); - // let time = elapsed.as_nanos(); - // println!("len = {}", res.len()); - // println!("Time elapsed: {}s", time as f64 / 1e9); + let elapsed = start.elapsed(); + let time = elapsed.as_nanos(); + println!("Time elapsed: {}s", time as f64 / 1e9); Ok(()) } -- cgit v1.2.3