Spring裏的Async註解實現異步操做

異步執行通常用來發送一些消息數據,數據一致性不要求過高的場景,對於spring來講,它把這個異步進行了封裝,使用一個註解就能夠實現。spring

用法

  1. 程序啓動時開啓@EnableAsync註解
  2. 創建新的類型,創建異步方法,爲方法添加@Async註解
  3. 在業務代碼中,@Autowired注入你的類型,使用它便可網絡

    咱們能夠關注到在配置task的時候,是有參數讓咱們配置線程池的數量的。由於這種實現方法,因此在同一個類中的方法調用,添加@async註解是失效的!,緣由是當你在同一個類中的時候,方法調用是在類體內執行的,spring沒法截獲這個方法調用.app

Async幾種方式

  1. 沒有返回值的,不會阻塞主線程,至關於開啓新線程在後臺執行這個任務
@Async
    public String sayHello2() throws InterruptedException {
        Thread.sleep(2 * 1000);//網絡鏈接中 。。。消息發送中。。。
        return "我愛你啊!";// 調用方調用後會當即返回,因此返回null
    }
  1. 帶有返回值的,返回類型必須爲Future<>,它會開啓新的線程執行任務,並阻塞主線程,執行完成後把結果返回給主線程
@Async
  public Future<String> asyncFunc() throws InterruptedException {
    int thinking = 2;
    Thread.sleep(thinking * 1000);
    System.out.println("async!");
    return new AsyncResult<String>("發送消息用了" + thinking + "秒");
  }

調用方法異步

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

執行結果async

async!
發送消息用了2秒
主線程執行完成
相關文章
相關標籤/搜索