成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

在Java中使用Callable、Future進(jìn)行并行編程

kgbook / 2245人閱讀

摘要：使用進(jìn)行并行編程在中進(jìn)行并行編程最常用的方式是繼承類或者實(shí)現(xiàn)接口。從開始提供了和兩個接口，通過使用它們可以在任務(wù)執(zhí)行完畢后得到執(zhí)行結(jié)果。

使用Callable、Future進(jìn)行并行編程

在Java中進(jìn)行并行編程最常用的方式是繼承Thread類或者實(shí)現(xiàn)Runnable接口。這兩種方式的缺點(diǎn)是在任務(wù)完成后無法直接獲取執(zhí)行結(jié)果，必須通過共享變量或線程間通信，使用起來很不方便。
從Java 1.5開始提供了Callable和Future兩個接口，通過使用它們可以在任務(wù)執(zhí)行完畢后得到執(zhí)行結(jié)果。
下面我們來學(xué)習(xí)下如何使用Callable、Future和FutureTask。

Callable接口

Callable接口位于java.util.concurrent包，這是一個泛型接口，里面只聲明了一個call()方法：

public interface Callable {
    T call() throws Exception;
}

一般配合ExecutorService接口來使用它，在ExecutorService接口中聲明了幾個重載的submit方法：

 Future submit(Callable task);
 Future submit(Runnable task, T result);
Future submit(Runnable task);

第一個submit方法里面的參數(shù)類型就是Callable，另外兩個本文暫時不涉及。

Future和FutureTask

Future接口的實(shí)現(xiàn)類可以對Runnable或者Callable的任務(wù)執(zhí)行取消、查詢、獲取結(jié)果的操作。
Future接口也位于java.util.concurrent包下：

public interface Future {
    /**
    *取消任務(wù)
    *@param mayInterruptIfRunning
    *是否允許取消正在執(zhí)行卻沒有執(zhí)行完畢的任務(wù)，如果設(shè)置true，則表示可以取消正在執(zhí)行過程中的任務(wù)
    *如果任務(wù)正在執(zhí)行，則返回true
    *如果任務(wù)還沒有執(zhí)行，則無論mayInterruptIfRunning為true還是false，返回true
    *如果任務(wù)已經(jīng)完成，則無論mayInterruptIfRunning為true還是false，返回false
    */
    boolean cancel(boolean mayInterruptIfRunning);
    /**
    *任務(wù)是否被取消成功，如果在任務(wù)正常完成前被取消成功，則返回 true
    */
    boolean isCancelled();
    /**
    *任務(wù)是否完成
    */
    boolean isDone();
    /**
    *通過阻塞獲取執(zhí)行結(jié)果
    */
    T get() throws InterruptedException, ExecutionException;
    /**
    *通過阻塞獲取執(zhí)行結(jié)果。如果在指定的時間內(nèi)沒有返回，則返回null
    */
    T get(long timeout, TimeUnit unit)
        throws InterruptedException, ExecutionException, TimeoutException;
}

總結(jié)下來Future提供了三種功能：

判斷任務(wù)是否完成


能夠中斷任務(wù)


能夠獲取任務(wù)執(zhí)行的結(jié)果

JDK中為我們提供了一個Future接口的實(shí)現(xiàn)類FutureTask，它有如下兩個構(gòu)造函數(shù)。

public FutureTask(Callable callable) {
}
public FutureTask(Runnable runnable, T result) {
}
示例代碼

使用Callable、Future

import java.util.concurrent.*;
public class Test {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newCachedThreadPool();
        Task task = new Task();
        Future future = executorService.submit(task);
        executorService.shutdown();
        
        System.out.println("主線程在執(zhí)行任務(wù)...");
        try {
            Thread.sleep(2000);
        } catch(InterruptedException ex) {
            ex.printStackTrace();
        }
         
        try {
            System.out.println("task運(yùn)行結(jié)果:"+future.get());
        } catch (InterruptedException ex) {
            ex.printStackTrace();
        } catch (ExecutionException ex) {
            ex.printStackTrace();
        }  
        System.out.println("所有任務(wù)執(zhí)行完畢");
    }
}
class Task implements Callable{
    @Override
    public Integer call() throws Exception {
        System.out.println("子線程在執(zhí)行任務(wù)...");
        //模擬任務(wù)耗時
        Thread.sleep(5000);
        return 1000;
    }
}

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

子線程在執(zhí)行任務(wù)...
主線程在執(zhí)行任務(wù)...
task運(yùn)行結(jié)果:1000
所有任務(wù)執(zhí)行完畢

使用Callable、FutureTask

import java.util.concurrent.*;
public class Test {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newCachedThreadPool();
        Task task = new Task();
        FutureTask futureTask = new FutureTask(task);
        executorService.submit(futureTask);
        executorService.shutdown();
        
        System.out.println("主線程在執(zhí)行任務(wù)...");
        try {
            Thread.sleep(2000);
        } catch (InterruptedException ex) {
            ex.printStackTrace();
        }
         
        try {
            System.out.println("task運(yùn)行結(jié)果:"+futureTask.get());
        } catch (InterruptedException ex) {
            ex.printStackTrace();
        } catch (ExecutionException ex) {
            ex.printStackTrace();
        }
         
        System.out.println("所有任務(wù)執(zhí)行完畢");
    }
}
class Task implements Callable{
    @Override
    public Integer call() throws Exception {
        System.out.println("子線程在執(zhí)行任務(wù)...");
        //模擬任務(wù)耗時
        Thread.sleep(5000);
        return 1000;
    }
}

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

子線程在執(zhí)行任務(wù)...
主線程在執(zhí)行任務(wù)...
task運(yùn)行結(jié)果:1000
所有任務(wù)執(zhí)行完畢

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/70710.html

相關(guān)文章

  • Java 8 并發(fā)教程：線程和執(zhí)行器

    摘要：在這個示例中我們使用了一個單線程線程池的。在延遲消逝后，任務(wù)將會并發(fā)執(zhí)行。這是并發(fā)系列教程的第一部分。第一部分線程和執(zhí)行器第二部分同步和鎖第三部分原子操作和 Java 8 并發(fā)教程：線程和執(zhí)行器 原文：Java 8 Concurrency Tutorial: Threads and Executors 譯者：BlankKelly 來源：Java8并發(fā)教程：Threads和Execut...

    jsdt 評論0 收藏0

  • java并發(fā)編程學(xué)習(xí)14--CompletableFuture(一)

    摘要：并行流與目前，我們對集合進(jìn)行計算有兩種方式并行流而更加的靈活，我們可以配置線程池的大小確保整體的計算不會因?yàn)榈却l(fā)生阻塞。 【回顧Future接口 Future接口時java5引入的，設(shè)計初衷是對將來某個時刻會發(fā)生的結(jié)果建模。它建模了一種異步計算，返回了一個執(zhí)行預(yù)算結(jié)果的引用。比如，你去干洗店洗衣服，店員會告訴你什么時候可以來取衣服，而不是讓你一直在干洗店等待。要使用Future只需...

    VioletJack 評論0 收藏0

  • (二)線程的應(yīng)用及挑戰(zhàn)

    摘要：上下文切換會影響到線程的執(zhí)行速度，對于系統(tǒng)來說意味著會消耗大量的時間減少上下文切換的方式無鎖并發(fā)編程，在多線程競爭鎖時，會導(dǎo)致大量的上下文切換。線程在中的使用在中實(shí)現(xiàn)多線程的方式比較簡單，因?yàn)橹刑峁┝朔浅７奖愕膩韺?shí)現(xiàn)多線程。 文章簡介 上一篇文章我們了解了進(jìn)程和線程的發(fā)展歷史、線程的生命周期、線程的優(yōu)勢和使用場景，這一篇，我們從Java層面更進(jìn)一步了解線程的使用 內(nèi)容導(dǎo)航 并發(fā)編程的...

    hqman 評論0 收藏0

  • Java多線程-Callable和Future

    摘要：類提供了一些有用的方法在線程池中執(zhí)行內(nèi)的任務(wù)。在線程池提交任務(wù)后返回了一個對象，使用它可以知道任務(wù)的狀態(tài)和得到返回的執(zhí)行結(jié)果。 Callable和Future出現(xiàn)的原因 創(chuàng)建線程的2種方式，一種是直接繼承Thread，另外一種就是實(shí)現(xiàn)Runnable接口。 這2種方式都有一個缺陷就是：在執(zhí)行完任務(wù)之后無法獲取執(zhí)行結(jié)果。 如果需要獲取執(zhí)行結(jié)果，就必須通過共享變量或者使用線程通信的方式來達(dá)...

    seasonley 評論0 收藏0

  • Java 線程池

    系統(tǒng)啟動一個線程的成本是比較高，使用線程池可以很好地提高性能，尤其是當(dāng)程序中需要創(chuàng)建大量生存期很短暫的線程時 線程池在系統(tǒng)啟動時即創(chuàng)建大量空閑線程，將一個Runnable、Callable對象—–>傳給線程池—–>線程池啟動里面的一個線程來執(zhí)行它們的run()或者call()方法———->當(dāng)線程執(zhí)行體執(zhí)行完成后，線程并不會死亡，而是再次返回線程池成為空閑狀態(tài)，等待下一個Runnable、Calla...

    ctriptech 評論0 收藏0

發(fā)表評論

0條評論

最新活動
閱讀需要支付1元查看
<