Implement a Multi-threaded Real-Time Data Processing Application in Java