Massive cleanup of Producer/Consumer code using Actor-based APIs.