summaryrefslogtreecommitdiff
path: root/graph-checker/src/main.rs
diff options
context:
space:
mode:
Diffstat (limited to 'graph-checker/src/main.rs')
-rw-r--r--graph-checker/src/main.rs49
1 files changed, 33 insertions, 16 deletions
diff --git a/graph-checker/src/main.rs b/graph-checker/src/main.rs
index a62143c..bea7d6a 100644
--- a/graph-checker/src/main.rs
+++ b/graph-checker/src/main.rs
@@ -35,22 +35,39 @@ async fn main() -> Result<(), sqlx::Error> {
// gi.par_bridge().for_each(|_| {});
- let gi = GengIterator::new(9);
-
- let start = Instant::now();
- let tasks: Vec<_> = gi
- .map(|g| {
- // let db = db.clone();
- tokio::spawn(compute::async_theorems1(g))
- })
- .collect();
-
- let res = futures::future::join_all(tasks).await;
- let elapsed = start.elapsed();
- let time = elapsed.as_nanos();
- let res = res.iter().map(|e| e.as_ref().unwrap()).collect::<Vec<_>>();
- println!("len = {}", res.len());
- println!("Time elapsed: {}s", time as f64 / 1e9);
+ let gi = GengIterator::new(7);
+
+ // let start = Instant::now();
+ // let tasks: Vec<_> = gi
+ // .map(|g| {
+ // // let db = db.clone();
+ // tokio::spawn(compute::async_theorems1(g))
+ // })
+ // .collect();
+
+ // let res: Vec<_> = gi.par_bridge().map(compute::apply_theorems).collect();
+ // 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 {
+ if pair.2 != 0 {
+ println!("{} {:?} {}", pair.0, cardinality, pair.2);
+ }
+ }
+ }
+
+ // for (a, b) in &res {
+ // println!("{a} {b:?}");
+ // }
+
+ // let res = futures::future::join_all(tasks).await;
+ // let elapsed = start.elapsed();
+ // let time = elapsed.as_nanos();
+ // let res = res.iter().map(|e| e.as_ref().unwrap()).collect::<Vec<_>>();
+ // println!("len = {}", res.len());
+ // println!("Time elapsed: {}s", time as f64 / 1e9);
// let start = Instant::now();
// let res = gi