欧美一级特黄大片做受成人-亚洲成人一区二区电影-激情熟女一区二区三区-日韩专区欧美专区国产专区

futuretask用法及使用場景介紹

FutureTask可用于異步獲取執(zhí)行結(jié)果或取消執(zhí)行任務(wù)的場景。通過傳入Runnable或者Callable的任務(wù)給FutureTask,直接調(diào)用其run方法或者放入線程池執(zhí)行,之后可以在外部通過FutureTask的get方法異步獲取執(zhí)行結(jié)果,因此,F(xiàn)utureTask非常適合用于耗時的計算,主線程可以在完成自己的任務(wù)后,再去獲取結(jié)果。另外,F(xiàn)utureTask還可以確保即使調(diào)用了多次run方法,它都只會執(zhí)行一次Runnable或者Callable任務(wù),或者通過cancel取消FutureTask的執(zhí)行等。

創(chuàng)新互聯(lián)網(wǎng)站建設(shè)服務(wù)商,為中小企業(yè)提供網(wǎng)站制作、做網(wǎng)站服務(wù),網(wǎng)站設(shè)計,網(wǎng)站托管、服務(wù)器托管等一站式綜合服務(wù)型公司,專業(yè)打造企業(yè)形象網(wǎng)站,讓您在眾多競爭對手中脫穎而出創(chuàng)新互聯(lián)。

1. FutureTask執(zhí)行多任務(wù)計算的使用場景

利用FutureTask和ExecutorService,可以用多線程的方式提交計算任務(wù),主線程繼續(xù)執(zhí)行其他任務(wù),當(dāng)主線程需要子線程的計算結(jié)果時,在異步獲取子線程的執(zhí)行結(jié)果。

package futuretask; 
import java.util.ArrayList; 
import java.util.List; 
import java.util.concurrent.Callable; 
import java.util.concurrent.ExecutionException; 
import java.util.concurrent.ExecutorService; 
import java.util.concurrent.Executors; 
import java.util.concurrent.FutureTask; 
public class FutureTaskForMultiCompute { 
  public static void main(String[] args) { 
    FutureTaskForMultiCompute inst=new FutureTaskForMultiCompute(); 
    // 創(chuàng)建任務(wù)集合 
    List<FutureTask<Integer>> taskList = new ArrayList<FutureTask<Integer>>(); 
    // 創(chuàng)建線程池 
    ExecutorService exec = Executors.newFixedThreadPool(5); 
    for (int i = 0; i < 10; i++) { 
      // 傳入Callable對象創(chuàng)建FutureTask對象 
      FutureTask<Integer> ft = new FutureTask<Integer>(inst.new ComputeTask(i, ""+i)); 
      taskList.add(ft); 
      // 提交給線程池執(zhí)行任務(wù),也可以通過exec.invokeAll(taskList)一次性提交所有任務(wù); 
      exec.submit(ft); 
    } 
    System.out.println("所有計算任務(wù)提交完畢, 主線程接著干其他事情!"); 
    // 開始統(tǒng)計各計算線程計算結(jié)果 
    Integer totalResult = 0; 
    for (FutureTask<Integer> ft : taskList) { 
      try { 
        //FutureTask的get方法會自動阻塞,直到獲取計算結(jié)果為止 
        totalResult = totalResult + ft.get(); 
      } catch (InterruptedException e) { 
        e.printStackTrace(); 
      } catch (ExecutionException e) { 
        e.printStackTrace(); 
      } 
    } 
    // 關(guān)閉線程池 
    exec.shutdown(); 
    System.out.println("多任務(wù)計算后的總結(jié)果是:" + totalResult); 
  } 
  private class ComputeTask implements Callable<Integer> { 
    private Integer result = 0; 
    private String taskName = ""; 
    public ComputeTask(Integer iniResult, String taskName){ 
      result = iniResult; 
      this.taskName = taskName; 
      System.out.println("生成子線程計算任務(wù): "+taskName); 
    } 
    public String getTaskName(){ 
      return this.taskName; 
    } 
    @Override 
    public Integer call() throws Exception { 
      // TODO Auto-generated method stub 
      for (int i = 0; i < 100; i++) { 
        result =+ i; 
      } 
      // 休眠5秒鐘,觀察主線程行為,預(yù)期的結(jié)果是主線程會繼續(xù)執(zhí)行,到要取得FutureTask的結(jié)果是等待直至完成。 
      Thread.sleep(5000); 
      System.out.println("子線程計算任務(wù): "+taskName+" 執(zhí)行完成!"); 
      return result; 
    } 
  } 
} 

2. FutureTask在高并發(fā)環(huán)境下確保任務(wù)只執(zhí)行一次

在很多高并發(fā)的環(huán)境下,往往我們只需要某些任務(wù)只執(zhí)行一次。這種使用情景FutureTask的特性恰能勝任。舉一個例子,假設(shè)有一個帶key的連接池,當(dāng)key存在時,即直接返回key對應(yīng)的對象;當(dāng)key不存在時,則創(chuàng)建連接。對于這樣的應(yīng)用場景,通常采用的方法為使用一個Map對象來存儲key和連接池對應(yīng)的對應(yīng)關(guān)系,典型的代碼如下面所示:

private Map<String, Connection> connectionPool = new HashMap<String, Connection>(); 
private ReentrantLock lock = new ReentrantLock(); 
public Connection getConnection(String key){ 
  try{ 
    lock.lock(); 
    if(connectionPool.containsKey(key)){ 
      return connectionPool.get(key); 
    } 
    else{ 
      //創(chuàng)建 Connection 
      Connection conn = createConnection(); 
      connectionPool.put(key, conn); 
      return conn; 
    } 
  } 
  finally{ 
    lock.unlock(); 
  } 
} 
//創(chuàng)建Connection 
private Connection createConnection(){ 
  return null; 
} 

在上面的例子中,我們通過加鎖確保高并發(fā)環(huán)境下的線程安全,也確保了connection只創(chuàng)建一次,然而確犧牲了性能。改用ConcurrentHash的情況下,幾乎可以避免加鎖的操作,性能大大提高,但是在高并發(fā)的情況下有可能出現(xiàn)Connection被創(chuàng)建多次的現(xiàn)象。這時最需要解決的問題就是當(dāng)key不存在時,創(chuàng)建Connection的動作能放在connectionPool之后執(zhí)行,這正是FutureTask發(fā)揮作用的時機,基于ConcurrentHashMap和FutureTask的改造代碼如下:

private ConcurrentHashMap<String,FutureTask<Connection>>connectionPool = new ConcurrentHashMap<String, FutureTask<Connection>>(); 
public Connection getConnection(String key) throws Exception{ 
  FutureTask<Connection>connectionTask=connectionPool.get(key); 
  if(connectionTask!=null){ 
    return connectionTask.get(); 
  } 
  else{ 
    Callable<Connection> callable = new Callable<Connection>(){ 
      @Override 
      public Connection call() throws Exception { 
        // TODO Auto-generated method stub 
        return createConnection(); 
      } 
    }; 
    FutureTask<Connection>newTask = new FutureTask<Connection>(callable); 
    connectionTask = connectionPool.putIfAbsent(key, newTask); 
    if(connectionTask==null){ 
      connectionTask = newTask; 
      connectionTask.run(); 
    } 
    return connectionTask.get(); 
  } 
} 
//創(chuàng)建Connection 
private Connection createConnection(){ 
  return null; 
} 

經(jīng)過這樣的改造,可以避免由于并發(fā)帶來的多次創(chuàng)建連接及鎖的出現(xiàn)。

總結(jié)

以上就是本文關(guān)于futuretask用法及使用場景介紹的全部內(nèi)容,希望對大家有所幫助。感興趣的朋友可以參閱:淺談Java多線程處理中Future的妙用(附源碼)、Java利用future及時獲取多線程運行結(jié)果、Java多線程ForkJoinPool實例詳解等,有什么問題可以隨時留言,歡迎各位參閱本站其他相關(guān)專題。

當(dāng)前題目:futuretask用法及使用場景介紹
文章路徑:http://aaarwkj.com/article18/jessdp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供標(biāo)簽優(yōu)化定制網(wǎng)站、網(wǎng)站維護網(wǎng)頁設(shè)計公司、GoogleApp設(shè)計

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)

成都定制網(wǎng)站建設(shè)
国产饥渴熟女在线三区| 日本成年网站在线观看| 人妻少妇系列一区二区| 亚洲精品入口一区二区| 91老熟女露脸大合集| 欧美日韩激情在线不卡三区| 一区二区三区熟妇人妻视频 | 欧美老熟妇精品一区二区| 色日韩在线观看视频| 国产片精品一区在线观看| 人妻一少妇一区二区三区| 免费日韩黄片在线观看| 打开网址国语一级黄色片| 激情五月,开心五月深情五月| 国产乱一伦一性一情一色| 亚洲一区二区三区久久精品| 日本精品专区在线观看| 成年视频免费观看视频| 亚洲av精二区三区四区| 亚洲毛片在线免费播放| 一区二区三区国产不卡| 免费高清日本一区二区三区视频| 成熟人妻中文字幕在线看| 成熟人妻一区二区三区人妻| 精品啪在线观看国产熟女| 欧美日韩丝袜一区二区| 少妇高潮叫床免费网站在线观看| 日韩免费黄色av网站| 欧美日韩欧美黄色三级| 日本一区二区免费高清不卡| 国产乱码精品免费一区二区av| 午夜精品三级一区二区三区| 五月天亚洲激情综合av| 在线一区二区三区成人观看| 国产精品国产精品无卡区| 日本亚洲欧美男人的天堂| 国产自拍最新在线视频| 欧美av精品一区二区三区| 亚洲黄色艳情视频录像| 亚洲成人乱码一区二区| 国产精品国产一级国产av|