sub accumulate {
    async {
        my %totals;
        while (defined (my $payload = $q2->dequeue())) {
            $totals{ $payload }++;
        };
        # Processing has finished
        print_to_json(\%totals);
    };
};