異步執(zhí)行一般用來(lái)發(fā)送一些消息數(shù)據(jù)，數(shù)據(jù)一致性不要求太高的場(chǎng)景，對(duì)于spring來(lái)說(shuō)，它把這個(gè)異步進(jìn)行了封裝，使用一個(gè)注解就可以實(shí)現(xiàn)。

何為異步調(diào)用？

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

@Async介紹

在Spring中，基于@Async標(biāo)注的方法，稱(chēng)之為異步方法；這些方法將在執(zhí)行的時(shí)候，將會(huì)在獨(dú)立的線程中被執(zhí)行，調(diào)用者無(wú)需等待它的完成，即可繼續(xù)其他的操作。

分為不帶參數(shù)的異步調(diào)用；帶參數(shù)的異步調(diào)用；調(diào)用返回Future的異步線程

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

在@Async標(biāo)注的方法，同時(shí)也適用了@Transactional進(jìn)行了標(biāo)注；在其調(diào)用數(shù)據(jù)庫(kù)操作之時(shí)，將無(wú)法產(chǎn)生事務(wù)管理的控制，原因就在于其是基于異步處理的操作。 那該如何給這些操作添加事務(wù)管理呢？可以將需要事務(wù)管理操作的方法放置到異步方法內(nèi)部，在內(nèi)部被調(diào)用的方法上添加@Transactional. 例如： 方法A，使用了@Async/@Transactional來(lái)標(biāo)注，但是無(wú)法產(chǎn)生事務(wù)控制的目的。 方法B，使用了@Async來(lái)標(biāo)注， B中調(diào)用了C、D，C/D分別使用@Transactional做了標(biāo)注，則可實(shí)現(xiàn)事務(wù)控制的目的。

用法

1.程序啟動(dòng)時(shí)開(kāi)啟@EnableAsync注解

2.建立新的類(lèi)型，建立異步方法，為方法添加@Async注解

3.在業(yè)務(wù)代碼中，@Autowired注入你的類(lèi)型，使用它即可

我們可以關(guān)注到在配置task的時(shí)候，是有參數(shù)讓我們配置線程池的數(shù)量的。因?yàn)檫@種實(shí)現(xiàn)方法，所以在同一個(gè)類(lèi)中的方法調(diào)用，添加@async注解是失效的！，原因是當(dāng)你在同一個(gè)類(lèi)中的時(shí)候，方法調(diào)用是在類(lèi)體內(nèi)執(zhí)行的，spring無(wú)法截獲這個(gè)方法調(diào)用.

Async幾種方式

1.沒(méi)有返回值的，不會(huì)阻塞主線程，相當(dāng)于開(kāi)啟新線程在后臺(tái)執(zhí)行這個(gè)任務(wù)

  @Async
  public String sayHello2() throws InterruptedException {
    Thread.sleep(2 * 1000);//網(wǎng)絡(luò)連接中 。。。消息發(fā)送中。。。
    return "我愛(ài)你啊!";// 調(diào)用方調(diào)用后會(huì)立即返回,所以返回null
  }

1.帶有返回值的，返回類(lèi)型必須為Future<>，它會(huì)開(kāi)啟新的線程執(zhí)行任務(wù)，并阻塞主線程，執(zhí)行完成后把結(jié)果返回給主線程

 @Async
 public Future<String> asyncFunc() throws InterruptedException {
  int thinking = 2;
  Thread.sleep(thinking * 1000);
  System.out.println("async!");
  return new AsyncResult<String>("發(fā)送消息用了" + thinking + "秒");
 }

調(diào)用方法

 @GetMapping("/lind-demo/asyncFunc")
 public void async() throws Exception {
  Future<String> future = null;
  future = asyncService.asyncFunc();
  System.out.println(future.get());
  System.out.println("主線程被阻塞執(zhí)行完成");
 }

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

async!
發(fā)送消息用了2秒
主線程執(zhí)行完成

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評(píng)論