sunnychan

Author: SunnnyChan

.idea/compiler.xml

@@ -45,5 +45,6 @@
         <module>spring-data</module>
         <module>spring-bean</module>
         <module>spring-cookbook</module>
+        <module>spring-task</module>
     </modules>
 </project>

.idea/encodings.xml

@@ -0,0 +1,6 @@
+# Spring Cookbook
+
+1. 获取配置信息
+
+2. 异步
+

pom.xml

@@ -36,6 +36,11 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>com.alibaba</groupId>
             <artifactId>fastjson</artifactId>

spring-cookbook/README.md

@@ -0,0 +1,48 @@
+package me.sunny.demo.spring.cookbook.async;
+
+import java.util.concurrent.Future;
+import java.util.concurrent.TimeUnit;
+
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.annotation.AsyncResult;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author [email protected]
+ * 测试异步执行
+ */
+
+@Component
+public class AsyncTask {
+
+    /**
+     * @param second sleep time
+     */
+    @Async
+    public Future<String> doTask1(Integer second) {
+        try {
+            System.out.println("Async do task 1 start : " + System.currentTimeMillis() / 1000);
+            TimeUnit.SECONDS.sleep(second);
+            System.out.println("Async do task 1 end : " + System.currentTimeMillis() / 1000);
+        } catch (InterruptedException e ) {
+            System.out.println("InterruptedException occur");
+        }
+        return new AsyncResult<>("task 1 return");
+    }
+
+    /**
+     * @param second sleep time
+     */
+    @Async
+    public Future<String> doTask2(Integer second) {
+        try {
+            System.out.println("Async do task 2 start : " + System.currentTimeMillis() / 1000);
+            TimeUnit.SECONDS.sleep(second);
+            System.out.println("Async do task 2 end : " + System.currentTimeMillis() / 1000);
+        } catch (InterruptedException e ) {
+            System.out.println("InterruptedException occur");
+        }
+        return new AsyncResult<>("task 2 return");
+    }
+
+}

spring-cookbook/pom.xml

@@ -0,0 +1,36 @@
+package me.sunny.demo.spring.cookbook.async;
+
+import java.util.concurrent.TimeUnit;
+
+import org.springframework.stereotype.Component;
+
+/**
+ * @author [email protected]
+ */
+
+@Component
+public class SyncTask {
+
+    public void doTask1() {
+        try {
+            System.out.println("do task 1 start : " + System.currentTimeMillis());
+            TimeUnit.SECONDS.sleep(1);
+            System.out.println("do task 1 end : " + System.currentTimeMillis());
+        } catch (InterruptedException e ) {
+            System.out.println("InterruptedException occur");
+        }
+
+    }
+
+    public void doTask2() {
+        try {
+            System.out.println("do task 2 start : " + System.currentTimeMillis());
+            TimeUnit.SECONDS.sleep(1);
+            System.out.println("do task 2 end : " + System.currentTimeMillis());
+        } catch (InterruptedException e ) {
+            System.out.println("InterruptedException occur");
+        }
+
+    }
+
+}

spring-cookbook/src/main/java/me/sunny/demo/spring/cookbook/async/AsyncTask.java

@@ -0,0 +1,4 @@
+/**
+ * 对比同步与异步
+ */
+package me.sunny.demo.spring.cookbook.async;

spring-cookbook/src/main/java/me/sunny/demo/spring/cookbook/async/SyncTask.java

@@ -0,0 +1,15 @@
+package me.sunny.demo.spring.cookbook.async;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableAsync;
+
+@SpringBootApplication
+@EnableAsync
+public class SpringApplicationForTest {
+
+    public static void main(String[] args){
+        SpringApplication.run(SpringApplicationForTest.class);
+    }
+
+}

spring-cookbook/src/main/java/me/sunny/demo/spring/cookbook/async/package-info.java

@@ -0,0 +1,60 @@
+package me.sunny.demo.spring.cookbook.async;
+
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Future;
+
+import me.sunny.demo.spring.cookbook.async.AsyncTask;
+import me.sunny.demo.spring.cookbook.async.SyncTask;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest
+public class TestAsync {
+
+    @Autowired
+    SyncTask syncTask;
+
+    @Autowired
+    AsyncTask asyncTask;
+
+    @Test
+    public void testSyncTask() {
+        syncTask.doTask1();
+        syncTask.doTask2();
+    }
+
+    /**
+     * task 1 先完成
+     * future1.get() 和 future2.get() 都阻塞
+     */
+    @Test
+    public void testAsyncTask1() throws InterruptedException, ExecutionException {
+        Future<String> future1 = asyncTask.doTask1(1);
+        Future<String> future2 = asyncTask.doTask2(2);
+        String result1 = future1.get();
+        System.out.println(result1);
+        String result2 = future2.get();
+        System.out.println(result2);
+    }
+
+    /**
+     * task 2 先完成
+     * future1.get() 会阻塞，future2.get()不会阻塞，因为 task 2 执行快，
+     * 在等待 task 1完成的时候，task 2已经执行完成。
+     */
+    @Test
+    public void testAsyncTask2() throws InterruptedException, ExecutionException {
+        Future<String> future1 = asyncTask.doTask1(2);
+        Future<String> future2 = asyncTask.doTask2(1);
+        String result1 = future1.get();
+        System.out.println(result1);
+        String result2 = future2.get();
+        System.out.println(result2);
+    }
+
+
+}