   []
   {:collect-thresh 0
    :signal-thresh  0
-   :processor      eager-probabilistic-vertex-processor
-   :scheduler      single-pass-scheduler
+   :processor      parallel-two-pass-processor
+   :scheduler      two-pass-scheduler
+   ;;:processor      eager-probabilistic-single-pass-processor
+   ;;:scheduler      single-pass-scheduler
    :max-ops        1e6
    :threads        #?(:clj (inc (.availableProcessors (Runtime/getRuntime))) :cljs 1)})
 


(defn parallel-collect-pass
  [thresh]
  (fn [vertices]
    (r/fold
     sub-pass-combine
     (fn [acc v]
       (if (should-collect? v thresh)


(defn parallel-signal-pass
  [thresh]
  (fn [workgroup-size vertices]
    (r/fold
     workgroup-size
     sub-pass-combine
     (fn [acc v]
       (if (should-signal? v thresh)
