Implement multithreading into the aggregation process.