async java to kotlin

Author: houko

async/src/main/java/info/xiaomo/anysc/AsyncMain.java renamed to async/src/main/java/info/xiaomo/anysc/AsyncMain.kt

@@ -1,13 +1,12 @@
-package info.xiaomo.anysc;
+package info.xiaomo.anysc
 
 
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
-import org.springframework.boot.autoconfigure.domain.EntityScan;
-import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
-import org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfiguration;
-import org.springframework.context.annotation.ComponentScan;
-import org.springframework.context.annotation.Configuration;
+import org.springframework.boot.SpringApplication
+import org.springframework.boot.autoconfigure.EnableAutoConfiguration
+import org.springframework.boot.autoconfigure.domain.EntityScan
+import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
+import org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfiguration
+import org.springframework.context.annotation.ComponentScan
 
 /**
  * 把今天最好的表现当作明天最新的起点．．～
@@ -18,18 +17,16 @@
  * @author : xiaomo
  * github: https://github.com/xiaomoinfo
  * email: xiaomo@xiaomo.info
-
+ *
  * Date: 2016/4/1 15:38
  * Description: RabbitMq启动器
  * Copyright(©) 2015 by xiaomo.
- **/
-@Configuration
-@EnableAutoConfiguration(exclude={DataSourceAutoConfiguration.class,HibernateJpaAutoConfiguration.class})
+ */
+@EnableAutoConfiguration(exclude = arrayOf(DataSourceAutoConfiguration::class, HibernateJpaAutoConfiguration::class))
 @ComponentScan("info.xiaomo")
 @EntityScan("info.xiaomo.*.model")
-public class AsyncMain {
-    public static void main(String[] args) throws Exception {
-        SpringApplication.run(AsyncMain.class, args);
-    }
+class AsyncMain
 
+fun main(args: Array<String>) {
+    SpringApplication.run(AsyncMain::class.java, *args)
 }

async/src/main/java/info/xiaomo/anysc/controller/TestController.java

@@ -0,0 +1,54 @@
+package info.xiaomo.anysc.controller
+
+import info.xiaomo.anysc.task.AsyncTask
+import info.xiaomo.core.base.Result
+import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.web.bind.annotation.RequestMapping
+import org.springframework.web.bind.annotation.RequestMethod
+import org.springframework.web.bind.annotation.RestController
+
+/**
+ * 把今天最好的表现当作明天最新的起点．．～
+ * いま 最高の表現 として 明日最新の始発．．～
+ * Today the best performance  as tomorrow newest starter!
+ * Created by IntelliJ IDEA.
+ *
+ * @author : xiaomo
+ * github: https://github.com/xiaomoinfo
+ * email: xiaomo@xiaomo.info
+ *
+ *
+ * Date: 2016/11/15 15:12
+ * Description: 用户实体类
+ * Copyright(©) 2015 by xiaomo.
+ */
+
+@RestController
+@RequestMapping("/")
+class TestController @Autowired
+constructor(private val task: AsyncTask) {
+
+    @RequestMapping(value = "/", method = arrayOf(RequestMethod.GET))
+    @Throws(Exception::class)
+    fun task(): Result<*> {
+        val start = System.currentTimeMillis()
+
+        val task1 = task.doTaskOne()
+        val task2 = task.doTaskTwo()
+        val task3 = task.doTaskThree()
+
+        while (true) {
+            if (task1.isDone && task2.isDone && task3.isDone) {
+                // 三个任务都调用完成，退出循环等待
+                break
+            }
+            Thread.sleep(1000)
+        }
+
+        val end = System.currentTimeMillis()
+
+        println("任务全部完成，总耗时：" + (end - start) + "毫秒")
+        return Result(end - start)
+    }
+
+}

async/src/main/java/info/xiaomo/anysc/controller/TestController.kt

@@ -0,0 +1,53 @@
+package info.xiaomo.anysc.task
+
+import org.springframework.scheduling.annotation.Async
+import org.springframework.scheduling.annotation.AsyncResult
+import org.springframework.stereotype.Component
+import java.util.*
+import java.util.concurrent.Future
+
+/**
+ * @author : xiaomo
+ */
+@Component
+open class AsyncTask {
+
+    @Async
+    @Throws(Exception::class)
+    open fun doTaskOne(): Future<String> {
+        println("开始做任务一")
+        val start = System.currentTimeMillis()
+        Thread.sleep(random.nextInt(10000).toLong())
+        val end = System.currentTimeMillis()
+        println("完成任务一，耗时：" + (end - start) + "毫秒")
+        return AsyncResult("任务一完成")
+    }
+
+    @Async
+    @Throws(Exception::class)
+    open fun doTaskTwo(): Future<String> {
+        println("开始做任务二")
+        val start = System.currentTimeMillis()
+        Thread.sleep(random.nextInt(10000).toLong())
+        val end = System.currentTimeMillis()
+        println("完成任务二，耗时：" + (end - start) + "毫秒")
+        return AsyncResult("任务二完成")
+    }
+
+    @Async
+    @Throws(Exception::class)
+    open fun doTaskThree(): Future<String> {
+        println("开始做任务三")
+        val start = System.currentTimeMillis()
+        Thread.sleep(random.nextInt(10000).toLong())
+        val end = System.currentTimeMillis()
+        println("完成任务三，耗时：" + (end - start) + "毫秒")
+        return AsyncResult("任务三完成")
+    }
+
+    companion object {
+
+        private val random = Random()
+    }
+
+}