Struct ThreadVoteCounter 

struct ThreadVoteCounter<'env, I, R> {
    num_candidates: usize,
    pascal: Option<&'env [Vec<I>]>,
    keep_factors: Arc<RwLock<Vec<R>>>,
}

Helper state to accumulate votes in a worker thread.

Fields

num_candidates: usize

Number of candidates in the election.

pascal: Option<&'env [Vec<I>]>

Pre-computed Pascal triangle.

keep_factors: Arc<RwLock<Vec<R>>>

Keep factors used in the current round.

Trait Implementations

impl<I, R> ThreadAccumulator<BallotImpl<BoxedFlatOrder>, VoteAccumulator<I, R>> for ThreadVoteCounter<'_, I, R>

where I: Integer, for<'a> &'a I: IntegerRef<I>, R: Rational<I>, for<'a> &'a R: RationalRef<&'a I, R>,

type Accumulator<'a> = (VoteAccumulator<I, R>, RwLockReadGuard<'a, Vec<R>>) where Self: 'a, I: 'a, R: 'a

Type to accumulate inputs into.

fn init(&self) -> Self::Accumulator<'_>

Creates a new accumulator to process inputs.

fn process_item<'a>( &'a self, accumulator: &mut Self::Accumulator<'a>, index: usize, ballot: &Ballot, )

Accumulates the given input item.

fn finalize<'a>( &'a self, accumulator: Self::Accumulator<'a>, ) -> VoteAccumulator<I, R>

Converts the given accumulator into an output.