From 8d05a42c30ddadae90f9877cee77ffd85fc5ff1a Mon Sep 17 00:00:00 2001
From: Nikhil Khatwani <nkhatwani85@gmail.com>
Date: Wed, 9 May 2018 18:03:35 +0530
Subject: [PATCH] Changes for BAEL-1657

---
 .../DeferredResultController.java             | 33 +++++++++++--------
 1 file changed, 19 insertions(+), 14 deletions(-)
 rename {spring-boot/src/main/java/com/baeldung/servlets => spring-rest/src/main/java/com/baeldung/controllers}/DeferredResultController.java (76%)

diff --git a/spring-boot/src/main/java/com/baeldung/servlets/DeferredResultController.java b/spring-rest/src/main/java/com/baeldung/controllers/DeferredResultController.java
similarity index 76%
rename from spring-boot/src/main/java/com/baeldung/servlets/DeferredResultController.java
rename to spring-rest/src/main/java/com/baeldung/controllers/DeferredResultController.java
index c43b0e6dc0..c61d51e1af 100644
--- a/spring-boot/src/main/java/com/baeldung/servlets/DeferredResultController.java
+++ b/spring-rest/src/main/java/com/baeldung/controllers/DeferredResultController.java
@@ -1,4 +1,4 @@
-package com.baeldung.servlets;
+package com.baeldung.controllers;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -9,6 +9,8 @@ import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RestController;
 import org.springframework.web.context.request.async.DeferredResult;
 
+import java.util.concurrent.ForkJoinPool;
+
 @RestController
 public class DeferredResultController {
 
@@ -16,14 +18,18 @@ public class DeferredResultController {
 
 	@GetMapping("/async-deferredresult")
 	public DeferredResult<ResponseEntity<?>> handleReqDefResult(Model model) {
-		LOG.info("Received async-deferredresult request");
-		DeferredResult<ResponseEntity<?>> output = new DeferredResult<>();
-		new Thread(() -> {
-			LOG.info("Processing in separate thread");
-			output.setResult(ResponseEntity.ok("ok"));
-		}).start();
-		LOG.info("servlet thread freed");
-		return output;
+	    LOG.info("Received async-deferredresult request");
+	    DeferredResult<ResponseEntity<?>> output = new DeferredResult<>();
+	    ForkJoinPool.commonPool().submit(() -> {
+	        LOG.info("Processing in separate thread");
+	        try {
+			    Thread.sleep(6000);
+	        } catch (InterruptedException e) {
+	        }
+	        output.setResult(ResponseEntity.ok("ok"));
+	    });
+	    LOG.info("servlet thread freed");
+	    return output;
 	}
 
 	public DeferredResult<ResponseEntity<?>> handleReqWithTimeouts(Model model) {
@@ -36,8 +42,7 @@ public class DeferredResultController {
 						ResponseEntity.status(HttpStatus.REQUEST_TIMEOUT).body("Request timeout occurred."));
 			}
 		});
-
-		new Thread(() -> {
+		ForkJoinPool.commonPool().submit(() -> {
 			LOG.info("Processing in separate thread");
 			try {
 				Thread.sleep(600l);
@@ -48,14 +53,14 @@ public class DeferredResultController {
 						.body("INTERNAL_SERVER_ERROR occurred."));
 			}
 
-		}).start();
+		});
 		LOG.info("servlet thread freed");
 		return deferredResult;
 	}
 
 	public DeferredResult<ResponseEntity<?>> handleAsyncFailedRequest(Model model) {
 		DeferredResult<ResponseEntity<?>> deferredResult = new DeferredResult<>();
-		new Thread(() -> {
+		ForkJoinPool.commonPool().submit(() -> {
 			try {
 				// Exception occurred in processing
 				throw new Exception();
@@ -64,7 +69,7 @@ public class DeferredResultController {
 				deferredResult.setErrorResult(ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR)
 						.body("INTERNAL_SERVER_ERROR occurred."));
 			}
-		}).start();
+		});
 		return deferredResult;
 	}