public void shutdown ( ) { singleton = null ; log . info ( "Shuting down GossipMonger" ) ; isShutdown . set ( true ) ; threadPool . shutdown ( ) ; // Disable new tasks from being submitted // TODO: Wait for messages to end processing shutdownAndAwaitTermination ( threadPool ) ; // Clean ThreadLocal ref . remove ( ) ; }
Shutdown GossipMonger and associated Threads