Analyze the following synchronous pseudocode for a data processing pipeline. Refactor it into a concurrent Go application. Utilize worker pools, unbuffered and buffered channels effectively to prevent race conditions and deadlocks. Explain how you manage the WaitGroup to ensure all goroutines complete before the program exits, and optimize for CPU utilization.