First pass doing hashing in consume() threads