Stop the scheduled tasks on disconnect

Author: franz1981

frameworks/Java/netty/src/main/java/hello/HelloServerHandler.java

@@ -10,6 +10,7 @@
 import java.text.SimpleDateFormat;
 import java.util.Date;
 import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.ScheduledFuture;
 import java.util.concurrent.TimeUnit;
 
 import com.jsoniter.output.JsonStream;
@@ -34,9 +35,10 @@ protected DateFormat initialValue() {
 
 	private HttpHeaders jsonHeaders = makeJsonHeaders(new AsciiString(FORMAT.get().format(new Date())));
 	private HttpHeaders plaintextHeaders = makePlaintextHeaders(new AsciiString(FORMAT.get().format(new Date())));
+	private ScheduledFuture<?> refreshHeaders;
 
 	public HelloServerHandler(ScheduledExecutorService service) {
-		service.scheduleWithFixedDelay(new Runnable() {
+		refreshHeaders = service.scheduleWithFixedDelay(new Runnable() {
 			private final DateFormat format = FORMAT.get();
 
 			@Override
@@ -113,4 +115,13 @@ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
 	public void channelReadComplete(ChannelHandlerContext ctx) {
 		ctx.flush();
 	}
+
+	@Override
+	public void channelInactive(ChannelHandlerContext ctx) throws Exception {
+		super.channelInactive(ctx);
+		if (refreshHeaders != null) {
+			refreshHeaders.cancel(false);
+			refreshHeaders = null;
+		}
+	}
 }