si tu passes à Java 9++ voir Flow.Publisher et en particulier SubmissionPublisher (faire joujou avec l'Executor)
Ce type d'architecture correspond bien à un schéma de programmation réactive.