Android異步方法以同步方式實(shí)現(xiàn)

更新時(shí)間：2018年07月19日 14:32:59 作者：落葉Ex

這篇文章主要為大家詳細(xì)介紹了Android異步方法以同步方式進(jìn)行的實(shí)現(xiàn)方法，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

Android強(qiáng)制異步轉(zhuǎn)同步方法，供大家參考，具體內(nèi)容如下

Android系統(tǒng)中規(guī)定耗時(shí)任務(wù)需要在異步線程中進(jìn)行，特別是網(wǎng)絡(luò)請(qǐng)求必須在異步線程中進(jìn)行否則會(huì)拋出NetworkOnMainThreadException,但是在一些特殊的情況我們需要保證在獲得到網(wǎng)絡(luò)請(qǐng)求結(jié)果之后在進(jìn)行余下操作，這時(shí)候便需要在UiThread中進(jìn)行相關(guān)操作。

這樣就需要用到線程阻塞的原理，這里可以借助Callable或FutureTask來(lái)實(shí)現(xiàn)。

public static String getSyncBusiness(final String url){

    try {
      FutureTask<String> task = new FutureTask<String>(new Callable<String>() {

        @Override
        public String call() throws Exception {
          URL u = new URL(url);
          HttpURLConnection connection = (HttpURLConnection) u.openConnection();
          connection.setDoInput(true);
          connection.setRequestMethod("GET");
          connection.connect();
          InputStream in = connection.getInputStream();
          BufferedReader br = new BufferedReader(new InputStreamReader(in, "utf8"));
          final StringBuilder sb = new StringBuilder();
          String line = null;
          while((line = br.readLine())!=null){
            sb.append(line);
          }
          return sb.toString();
        }
      });

      new Thread(task).start();

      return task.get();
    } catch (Exception e) {
      e.printStackTrace();
      throw new RuntimeException("網(wǎng)絡(luò)訪問(wèn)錯(cuò)誤");
    }

}

FutureTask接口是一個(gè)泛型接口，可以設(shè)置需要返回的類型，并且可以看出該方法為了方便程序員的操作，巧妙的通過(guò)拋出一個(gè)總Exception來(lái)保證方法統(tǒng)一執(zhí)行統(tǒng)一判斷，類似于RxJava的Exception機(jī)制。并且通過(guò)源碼可以看出，該接口實(shí)現(xiàn)了RunnableFuture<>接口，而RunnableFuture接口又繼承于Runnable這也就解釋了為什么可以直接在new Thread中傳入Task對(duì)象。

可以理解為FuturTask通過(guò)實(shí)現(xiàn)Runnable對(duì)子線程進(jìn)行驅(qū)動(dòng)，進(jìn)行異步的網(wǎng)絡(luò)請(qǐng)求等操作，但是并沒(méi)有進(jìn)行異步并發(fā)操作，而是同時(shí)阻塞了UI線程，直到該子線程執(zhí)行完畢。

除了以上還可以直接使用Callable接口，需要注意，Callable需要線程池ExecutorService才可以進(jìn)行驅(qū)動(dòng)。

public static String getSyncBusiness2(final String url){

    try {
      Callable<String> callable = new Callable<String>() {
        @Override
        public String call() throws Exception {
          URL u = new URL(url);
          HttpURLConnection connection = (HttpURLConnection) u.openConnection();
          connection.setDoInput(true);
          connection.setRequestMethod("GET");
          connection.connect();
          InputStream in = connection.getInputStream();
          BufferedReader br = new BufferedReader(new InputStreamReader(in, "utf8"));
          final StringBuilder sb = new StringBuilder();
          String line = null;
          while((line = br.readLine())!=null){
            sb.append(line);
          }
          return sb.toString();
        }
      };
      ExecutorService exec = Executors.newFixedThreadPool(1);
      Future<String> task = exec.submit(callable);
      return task.get();
    } catch (Exception e) {
      e.printStackTrace();
      throw new RuntimeException("網(wǎng)絡(luò)訪問(wèn)錯(cuò)誤");
    }
  }

由于原理終歸是對(duì)UI線程進(jìn)行了阻塞，所有非特別需要不推薦使用，阻塞時(shí)間過(guò)長(zhǎng)同樣會(huì)觸發(fā)ANR。

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

您可能感興趣的文章: