非同步呼叫

在解釋非同步呼叫之前，我們先來看同步呼叫的定義；同步就是整個處理過程順序執行，當各個過程都執行完畢，並返回結果。 非同步呼叫則是隻是傳送了呼叫的指令，呼叫者無需等待被呼叫的方法完全執行完畢,繼續執行下面的流程。例如， 在某個呼叫中，需要順序呼叫 A,B,C三個過程方法；如他們都是同步呼叫，則需要將他們都順序執行完畢之後，過程才執行完畢； 如B為一個非同步的呼叫方法，則在執行完A之後，呼叫B，並不等待B完成，而是執行開始呼叫C，待C執行完畢之後，就意味著這個過程執行完畢了。

概述說明

Spring中通過任務執行器(TaskExecutor)來實現多執行緒和併發程式設計。使用ThreadPoolTaskExecutor可實現一個基於執行緒池的TaskExcutor。而實際開發中任務一般是非同步的，我們可以在配置類中通過@EnableAsync開啟對非同步任務的支援，並通過在實際執行的Bean的方法中使用@Async註解來宣告其是一個非同步任務。

從Spring3開始提供了@Async註解，該註解可以被標註在方法上，以便非同步地呼叫該方法。呼叫者將在呼叫時先返回結果標誌，方法的實際執行將提交給Spring TaskExecutor的任務中，由指定的執行緒池中的執行緒執行。

@Async應用自定義執行緒池配置類

/**
 * @author 佛大Java程式設計師
 * @since 1.0.0
 */
@Configuration
@ComponentScan("com.whl.asyncdemo")
@EnableAsync
public class TaskExecutorConfig implements AsyncConfigurer {

  @Override
  public Executor getAsyncExecutor() {
  ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
    taskExecutor.setCorePoolSize(5);
    taskExecutor.setMaxPoolSize(10);
    taskExecutor.setQueueCapacity(25);
    taskExecutor.initialize();
    return taskExecutor;
  }

  @Override
  public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
    return null;
  }
}

說明：

* 利用@EnableAsync 註解開啟非同步任務支援

* 自定義執行緒池需要定義的配置類中實現AsyncConfigurer介面並重寫getAsyncExecutor()，返回一個ThreadPoolTaskExecutor，這樣我們就獲得了一個基於執行緒池的TaskExecutor

執行類

/**
 * @author 佛大Java程式設計師
 * @since 1.0.0
 */
@Service
public class AsyncTaskService {

  @Async
  public void executeAsyncTask(Integer i){
    System.out.println("執行非同步任務1：" + i);
  }

  @Async
  public void executeAsyncTaskPlus(Integer i){
    System.out.println("執行非同步任務2 " +(i+1));
  }}

說明:

@Async註解表明方法是個非同步方法，如果註解在類級別，則表明該類所有的方法都是非同步方法，而這裡的方法自動注入使用ThreadPoolTaskExecutor作為TaskExecutor。

測試類

/**
 * @author 佛大Java程式設計師
 * @since 1.0.0
 */
public class Main {

  public static void main(String[] args) {

    AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(TaskExecutorConfig.class);
    AsyncTaskService asyncTaskService = context.getBean(AsyncTaskService.class);

    for (int i = 0; i < 5 ; i++) {
      asyncTaskService.executeAsyncTask(i);
      asyncTaskService.executeAsyncTaskPlus(i);
    }

    //校驗非同步方法是否先返回結果值
    System.out.println("返回執行成功，驗證非同步是否先返回結果值");
    context.close();

  }
}

執行結果

註釋@Async

放開@Async註釋

@Async應用預設執行緒池

待補充

@Async呼叫中的事務處理機制?

在@Async標註的方法，同時也適用了@Transactional進行了標註；在其呼叫資料庫操作之時，將無法產生事務管理的控制，原因就在於其是基於非同步處理的操作。那該如何給這些操作新增事務管理呢？可以將需要事務管理操作的方法放置到非同步方法內部，在內部被呼叫的方法上新增@Transactional.

(1)使用了@Async/@Transactional來標註，但是無法產生事務控制的目的。

(2)使用了@Async來標註， B中呼叫了C、D，C/D分別使用@Transactional做了標註，則可實現事務控制的目的。

專案實戰

WKD專案裡面使用Easypoi技術來匯出Excel，匯出資料量資料量不大的時候用同步匯出也沒事，但是對於資料量大且需要匯出的資料封裝業務較複雜，就會出現應用OOM或者出現響應超時。為了解決此問題，通過用執行緒池非同步匯出的方式實現。

到此這篇關於Spring中@Async註解實現非同步調詳解的文章就介紹到這了,更多相關Spring @Async註解非同步呼叫內容請搜尋我們以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援我們！