Threading implemented

kani-driver/src/harness_runner.rs

@@ -8,6 +8,7 @@ use std::path::Path;
 use std::thread;
 use std::sync::mpsc;
 use std::sync::Arc;
+use std::time::Instant;
 
 use crate::args::OutputFormat;
 use crate::call_cbmc::{VerificationResult, VerificationStatus};
@@ -44,14 +45,18 @@ impl<'sess, 'pr> HarnessRunner<'sess, 'pr> {
         self.check_stubbing(harnesses)?;
 
         let sorted_harnesses = crate::metadata::sort_harnesses_by_loc(harnesses);
-
+        let max_threads = 8; 
         let pool = {
             let mut builder = rayon::ThreadPoolBuilder::new();
-            if let Some(x) = self.sess.args.jobs() {
-                builder = builder.num_threads(x);
+            let mut threads = sorted_harnesses.len();
+            if threads > max_threads {
+                threads = max_threads;
             }
+            builder = builder.num_threads(threads);
             builder.build()?
         };
+
+        let before = Instant::now();
 
         let results = pool.install(|| -> Result<Vec<HarnessResult<'pr>>> {
             sorted_harnesses
@@ -74,7 +79,9 @@ impl<'sess, 'pr> HarnessRunner<'sess, 'pr> {
                 .collect::<Result<Vec<_>>>()
         })?;
 
-       Ok(results)
+        println!("Elapsed Time: {:.2?}\n", before.elapsed());
+
+        Ok(results)
     }
 
     /// Return an error if the user is trying to verify a harness with stubs without enabling the