How would you design a thread-safe input/output system for processing real-time telemetry data from manufacturing sensors?