[FIX] #26 SpringBootAsync

Author: heowc

SpringBootAsync/src/main/kotlin/com/example/kotlin/config/AsyncConfig.kt

@@ -0,0 +1,23 @@
+package com.example.kotlin.config
+
+import org.springframework.context.annotation.Configuration
+import org.springframework.scheduling.annotation.AsyncConfigurerSupport
+import org.springframework.scheduling.annotation.EnableAsync
+
+import java.util.concurrent.Executor
+import java.util.concurrent.Executors
+
+@Configuration
+@EnableAsync
+class AsyncConfig : AsyncConfigurerSupport() {
+
+    override fun getAsyncExecutor(): Executor {
+        //		ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        //		executor.setCorePoolSize(2);
+        //		executor.setMaxPoolSize(10);
+        //		executor.setQueueCapacity(500);
+        //		executor.setThreadNamePrefix("heowc-async-");
+        //		executor.initialize();
+        return Executors.newWorkStealingPool()
+    }
+}

SpringBootAsync/src/main/kotlin/com/example/kotlin/service/BasicService.kt

@@ -0,0 +1,35 @@
+package com.example.kotlin.service
+
+import org.slf4j.LoggerFactory
+import org.springframework.scheduling.annotation.Async
+import org.springframework.stereotype.Service
+
+@Service
+class BasicService {
+
+    @Async
+    fun onAsync() {
+        try {
+            Thread.sleep(1000)
+        } catch (e: InterruptedException) {
+            e.printStackTrace()
+        }
+
+        logger.info("onAsync")
+    }
+
+    fun onSync() {
+        try {
+            Thread.sleep(1000)
+        } catch (e: InterruptedException) {
+            e.printStackTrace()
+        }
+
+        logger.info("onSync")
+    }
+
+    companion object {
+
+        private val logger = LoggerFactory.getLogger(BasicService::class.java)
+    }
+}

SpringBootAsync/src/main/kotlin/com/example/kotlin/web/BasicController.kt

@@ -0,0 +1,52 @@
+package com.example.kotlin.web
+
+import com.example.kotlin.service.BasicService
+import org.slf4j.LoggerFactory
+import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.http.HttpHeaders
+import org.springframework.http.MediaType
+import org.springframework.web.bind.annotation.GetMapping
+import org.springframework.web.bind.annotation.PathVariable
+import org.springframework.web.bind.annotation.RestController
+import org.springframework.web.reactive.function.client.WebClient
+import reactor.core.publisher.Mono
+
+@RestController
+class BasicController {
+
+    @Autowired
+    private lateinit var service: BasicService
+
+    private val logger = LoggerFactory.getLogger(BasicController::class.java)
+
+    private val webClient = WebClient.builder()
+            .baseUrl("https://api.github.com")
+            .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_UTF8_VALUE)
+            .build()
+
+    @GetMapping("/async")
+    fun goAsync(): Mono<String> {
+        service.onAsync()
+        val str = "Hello Spring Boot Async!!"
+        logger.info(str)
+        logger.info("==================================")
+        return Mono.just(str)
+    }
+
+    @GetMapping("/sync")
+    fun goSync(): Mono<String> {
+        service.onSync()
+        val str = "Hello Spring Boot Sync!!"
+        logger.info(str)
+        logger.info("==================================")
+        return Mono.just(str)
+    }
+
+    @GetMapping("/{userName}")
+    fun showGithubReposByUserName(@PathVariable userName: String): Mono<List<*>> {
+        return webClient.get()
+                .uri(String.format("/users/%s/repos", userName))
+                .retrieve()
+                .bodyToMono(List::class.java)
+    }
+}