快捷導(dǎo)航

java異步調(diào)用的4種實(shí)現(xiàn)方法

更新時(shí)間：2022年03月11日 09:34:27 作者：未月廿三

日常開發(fā)中,會(huì)經(jīng)常遇到說,前臺(tái)調(diào)服務(wù)，本文主要介紹了java異步調(diào)用的4種實(shí)現(xiàn)方法，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

一.利用多線程

直接new線程

Thread t = new Thread(){
  @Override
  public void run() {
    longTimeMethod();
  }
};

使用線程池

private ExecutorService executor = Executors.newCachedThreadPool() ;

    public void fun() throws Exception {

        executor.submit(new Runnable(){

            @override

                public void run() {

                    try {
                     //要執(zhí)行的業(yè)務(wù)代碼，我們這里沒有寫方法，可以讓線程休息幾秒進(jìn)行測(cè)試

                        Thread.sleep(10000);

                        System.out.print("睡夠啦~");

                    }catch(Exception e) {

                        throw new RuntimeException("報(bào)錯(cuò)啦??！");

                    }

                }

        });

    }

二.采用Spring 的異步方法去執(zhí)行(無返回值)

在啟動(dòng)類或者配置類加上 @EnableAsync 注解.

package me.deweixu.aysncdemo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;

@EnableAsync
@SpringBootApplication
public class AysncDemoApplication {

 public static void main(String[] args) {
  SpringApplication.run(AysncDemoApplication.class, args);
 }
}

先把longTimeMethod 封裝到Spring的異步方法中，這個(gè)方法一定要寫在Spring管理的類中，注意注解@Async

@Async注解可以用在方法上,也可以用在類上,用在類上,對(duì)類里面所有方法起作用

@Service
public class AsynchronousService{
  @Async
  public void springAsynchronousMethod(){
    longTimeMethod();
  }
}

其他類調(diào)用這個(gè)方法。這里注意，一定要其他的類，如果在同類中調(diào)用，是不生效的。具體原因，可以去學(xué)習(xí)一下Spring AOP的原理

@Autowired
private AsynchronousService asynchronousService;

public void useAsynchronousMethod(){
  //我們需要執(zhí)行的代碼1
  asynchronousService.springAsynchronousMethod();
 //我們需要執(zhí)行的代碼2
}

三.采用Spring 的異步方法+Future接收返回值

先把longTimeMethod 封裝到Spring的異步方法中，這個(gè)異步方法的返回值是Future的實(shí)例。這個(gè)方法一定要寫在Spring管理的類中，注意注解@Async。

@Service
public class AsynchronousService{
  @Async
  public Future springAsynchronousMethod(){
    Integer result = longTimeMethod();
    return new AsyncResult(result);
  }
}

其他類調(diào)用這個(gè)方法。這里注意，一定要其他的類，如果在同類中調(diào)用，是不生效的。

如果調(diào)用之后接收返回值,不對(duì)返回值進(jìn)行操作則為異步操作,進(jìn)行操作則轉(zhuǎn)為同步操作,等待對(duì)返回值操作完之后,才會(huì)繼續(xù)執(zhí)行主進(jìn)程下面的流程

@Autowired
private AsynchronousService asynchronousService;

public void useAsynchronousMethod(){
    Future future = asynchronousService.springAsynchronousMethod();
    future.get(1000, TimeUnit.MILLISECONDS);
}

四.原生Future方法

//我們需要執(zhí)行的代碼1
Future future = longTimeMethod2();
//我們需要執(zhí)行的代碼2
Integer result = future.get();

可以看到，我們調(diào)用longTimeMethod2返回一個(gè)Future對(duì)象（注意了，這里的longTimeMethod2當(dāng)然不是上面的longTimeMethod），然后處理“我們需要執(zhí)行的代碼2”，到了需要返回結(jié)果的時(shí)候直接調(diào)用future.get()便能獲取到返回值。下面我們來看看longTimeMethod2如何實(shí)現(xiàn)。

private Future longTimeMethod2() {
  //創(chuàng)建線程池
  ExecutorService threadPool = Executors.newCachedThreadPool();
  //獲取異步Future對(duì)象
  Future future = threadPool.submit(new Callable() {
    @Override
    public Integer call() throwsException {
        return longTimeMethod();
    }
  });
  return future;
}