wip

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