@@ -23,7 +23,6 @@ use std::sync::{Arc, Condvar as SCondvar, Mutex as SMutex};
2323use std:: thread:: { self , JoinHandle } ;
2424
2525use cio:: IoChannel ;
26- use num_cpus;
2726use parking_lot:: { Mutex , RwLock } ;
2827use primitives:: { H256 , U256 } ;
2928
@@ -36,8 +35,8 @@ use crate::types::{BlockStatus as Status, VerificationQueueInfo as QueueInfo};
3635const MIN_MEM_LIMIT : usize = 16384 ;
3736const MIN_QUEUE_LIMIT : usize = 512 ;
3837
39- // maximum possible number of verification threads.
40- const MAX_VERIFIERS : usize = 8 ;
38+ // number of verification threads.
39+ const NUM_VERIFIERS : usize = 2 ;
4140
4241/// Type alias for block queue convenience.
4342pub type BlockQueue = VerificationQueue < kind:: Blocks > ;
@@ -150,10 +149,9 @@ impl<K: Kind> VerificationQueue<K> {
150149 let empty = Arc :: new ( SCondvar :: new ( ) ) ;
151150 let more_to_verify = Arc :: new ( SCondvar :: new ( ) ) ;
152151
153- let num_verifiers = cmp:: min ( num_cpus:: get ( ) , MAX_VERIFIERS ) ;
154- let mut verifier_handles = Vec :: with_capacity ( num_verifiers) ;
152+ let mut verifier_handles = Vec :: with_capacity ( NUM_VERIFIERS ) ;
155153
156- for i in 0 ..num_verifiers {
154+ for i in 0 ..NUM_VERIFIERS {
157155 let engine = engine. clone ( ) ;
158156 let verification = verification. clone ( ) ;
159157 let more_to_verify = more_to_verify. clone ( ) ;
0 commit comments