欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Spring中@Async注解實現(xiàn)異步調(diào)詳解

 更新時間:2020年04月20日 08:36:23   作者:佛大Java程序員  
在本篇文章里小編給大家分享的是關(guān)于Spring中@Async注解實現(xiàn)異步調(diào)詳解內(nèi)容,需要的朋友們可以學(xué)習(xí)下。

異步調(diào)用

在解釋異步調(diào)用之前,我們先來看同步調(diào)用的定義;同步就是整個處理過程順序執(zhí)行,當(dāng)各個過程都執(zhí)行完畢,并返回結(jié)果。 異步調(diào)用則是只是發(fā)送了調(diào)用的指令,調(diào)用者無需等待被調(diào)用的方法完全執(zhí)行完畢,繼續(xù)執(zhí)行下面的流程。例如, 在某個調(diào)用中,需要順序調(diào)用 A, B, C三個過程方法;如他們都是同步調(diào)用,則需要將他們都順序執(zhí)行完畢之后,過程才執(zhí)行完畢; 如B為一個異步的調(diào)用方法,則在執(zhí)行完A之后,調(diào)用B,并不等待B完成,而是執(zhí)行開始調(diào)用C,待C執(zhí)行完畢之后,就意味著這個過程執(zhí)行完畢了。

概述說明

Spring中通過任務(wù)執(zhí)行器(TaskExecutor)來實現(xiàn)多線程和并發(fā)編程。使用ThreadPoolTaskExecutor可實現(xiàn)一個基于線程池的TaskExcutor。而實際開發(fā)中任務(wù)一般是異步的,我們可以在配置類中通過@EnableAsync開啟對異步任務(wù)的支持,并通過在實際執(zhí)行的Bean的方法中使用@Async注解來聲明其是一個異步任務(wù)。

從Spring3開始提供了@Async注解,該注解可以被標(biāo)注在方法上,以便異步地調(diào)用該方法。調(diào)用者將在調(diào)用時先返回結(jié)果標(biāo)志,方法的實際執(zhí)行將提交給Spring TaskExecutor的任務(wù)中,由指定的線程池中的線程執(zhí)行。

@Async應(yīng)用自定義線程池配置類

/**
 * @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 注解開啟異步任務(wù)支持

* 自定義線程池需要定義的配置類中實現(xiàn)AsyncConfigurer接口并重寫getAsyncExecutor(),返回一個ThreadPoolTaskExecutor,這樣我們就獲得了一個基于線程池的TaskExecutor

執(zhí)行類

/**
 * @author 佛大Java程序員
 * @since 1.0.0
 */
@Service
public class AsyncTaskService {

  @Async
  public void executeAsyncTask(Integer i){
    System.out.println("執(zhí)行異步任務(wù)1:" + i);
  }

  @Async
  public void executeAsyncTaskPlus(Integer i){
    System.out.println("執(zhí)行異步任務(wù)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);
    }

    //校驗異步方法是否先返回結(jié)果值
    System.out.println("返回執(zhí)行成功,驗證異步是否先返回結(jié)果值");
    context.close();

  }
}

執(zhí)行結(jié)果

注釋@Async

放開@Async注釋

 

@Async應(yīng)用默認(rèn)線程池

待補充

@Async調(diào)用中的事務(wù)處理機制?

在@Async標(biāo)注的方法,同時也適用了@Transactional進(jìn)行了標(biāo)注;在其調(diào)用數(shù)據(jù)庫操作之時,將無法產(chǎn)生事務(wù)管理的控制,原因就在于其是基于異步處理的操作。那該如何給這些操作添加事務(wù)管理呢?可以將需要事務(wù)管理操作的方法放置到異步方法內(nèi)部,在內(nèi)部被調(diào)用的方法上添加@Transactional.

(1) 使用了@Async/@Transactional來標(biāo)注,但是無法產(chǎn)生事務(wù)控制的目的。

(2) 使用了@Async來標(biāo)注,  B中調(diào)用了C、D,C/D分別使用@Transactional做了標(biāo)注,則可實現(xiàn)事務(wù)控制的目的。

項目實戰(zhàn)

WKD項目里面使用Easypoi技術(shù)來導(dǎo)出Excel,導(dǎo)出數(shù)據(jù)量數(shù)據(jù)量不大的時候用同步導(dǎo)出也沒事,但是對于數(shù)據(jù)量大且需要導(dǎo)出的數(shù)據(jù)封裝業(yè)務(wù)較復(fù)雜,就會出現(xiàn)應(yīng)用OOM或者出現(xiàn)響應(yīng)超時。為了解決此問題,通過用線程池異步導(dǎo)出的方式實現(xiàn)。

到此這篇關(guān)于Spring中@Async注解實現(xiàn)異步調(diào)詳解的文章就介紹到這了,更多相關(guān)Spring @Async注解異步調(diào)用內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

最新評論