Làm cách nào để chạy phương thức Không đồng bộ với mùa xuân?

Question

Mã sau đây được giả sử để làm việc Không đồng bộ nhưng thay vào đó nó chờ phần Async kết thúc và sau đó đi. Làm cách nào để tôi có thể chạy phương thức blah() Không đồng bộ?

spring.xml

<?xml version="1.0" encoding="UTF-8"?> 
<beans 
    xmlns="http://www.springframework.org/schema/beans" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xmlns:task="http://www.springframework.org/schema/task" 
    xmlns:context="http://www.springframework.org/schema/context" 
    xsi:schemaLocation=" 
     http://www.springframework.org/schema/beans 
     http://www.springframework.org/schema/beans/spring-beans-3.0.xsd 
     http://www.springframework.org/schema/task 
     http://www.springframework.org/schema/task/spring-task-3.0.xsd 
     http://www.springframework.org/schema/context 
     http://www.springframework.org/schema/context/spring-context-3.0.xsd 
    "> 

    <!-- Activates @Scheduled and @Async annotations for scheduling --> 
    <task:annotation-driven /> 

    <bean id="test" 
     class="com.spring.test.Test"> 
</beans> 

Test.java

@Path("/test") 
public class Test 
{ 
    @GET 
    @Path("/test") 
    @Produces("text/plain") 
    public String tester() 
    { 
    return "Running..."; 
    } 

    @GET 
    @Path("/triggerNew") 
    @Produces("text/plain") 
    public String triggerNew() 
    { 
    System.out.println("BEFORE " + new Date() + " BEFORE"); 

    new Process().blah(); 

    System.out.println("AFTER " + new Date() + " AFTER"); 
    return "TRIGGERED"; 
    } 
} 

Process.java

@Component 
    public class Process 
    { 
     @Async 
     public void blah() 
     { 
     try 
     { 
      Thread.currentThread().sleep(5000); 
     } 
     catch (InterruptedException e) 
     { 
      e.printStackTrace(); 
     } 
     System.out.println("NEW THREAD " + new Date() + " NEW THREAD"); 
     } 
    } 

Answer 1

@Async chỉ hoạt động khi bạn chú thích các bean được quản lý bởi Spring, không phải các lớp tùy ý. Bạn cần xác định Process làm bean Spring và sau đó chèn nó vào lớp điều khiển của bạn, ví dụ:

<bean id="test" class="com.spring.test.Test"> 
    <property name="process"> 
     <bean class="com.spring.test.Process"/> 
    </property> 
</bean> 

---

public class Test { 
    private Process process; 

    public void setProcess(Process process) { 
     this.process = process; 
    } 

    ... 

    public String triggerNew() { 
     process.blah(); 
    } 
} 

Answer 2

Hoặc bạn có thể thực hiện nhiệm vụ của bạn bằng tay với TaskExecutor. Chỉ cần xác định người thi hành trong bối cảnh:

<bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"/> 

hơn bạn có thể thực hiện nhiệm vụ Yor:

taskExecutor.execute(new Process()); 

Nhưng trong trường hợp này lớp Process bạn phải thực hiện giao diện Runnable