1. Each async worker now writes to a concurrent queue instead