Add better thread management

[spartanny]

Currently using new Thread() to submit the SubscriberWorker runnable task.
Utilise a better thread management tool such as :

• Executors
• CountdownLatch, etc