|
@@ -179,7 +179,6 @@ impl Raft {
|
|
|
.enable_time()
|
|
.enable_time()
|
|
|
.thread_name(format!("raft-instance-{}", me))
|
|
.thread_name(format!("raft-instance-{}", me))
|
|
|
.worker_threads(peer_size)
|
|
.worker_threads(peer_size)
|
|
|
- .max_threads(peer_size * 2)
|
|
|
|
|
.build()
|
|
.build()
|
|
|
.expect("Creating thread pool should not fail");
|
|
.expect("Creating thread pool should not fail");
|
|
|
let peers = peers.into_iter().map(Arc::new).collect();
|
|
let peers = peers.into_iter().map(Arc::new).collect();
|