1. 程式人生 > >使用Future和Callable建立執行緒

使用Future和Callable建立執行緒

建立執行緒還可以使用 Future和Callabe來建立執行緒。

Future就是對於具體的Runnable或者Callable任務的執行結果進行取消、查詢是否完成、獲取結果。必要時可以通過get方法獲取執行結果,該方法會阻塞直到任務返回結果。

  Future類位於java.util.concurrent包下,它是一個介面:

public interface Future<V> {
    boolean cancel(boolean mayInterruptIfRunning);
    boolean isCancelled();
    boolean isDone();
    V get
() throws InterruptedException, ExecutionException; V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException; }

  在Future介面中聲明瞭5個方法,下面依次解釋每個方法的作用:

cancel 方法用來取消任務,如果取消任務成功則返回true,如果取消任務失敗則返回false。引數mayInterruptIfRunning表示是否允許取消正在執行卻沒有執行完畢的任務,如果設定true,則表示可以取消正在執行過程中的任務。如果任務已經完成,則無論mayInterruptIfRunning為true還是false,此方法肯定返回false,即如果取消已經完成的任務會返回false;如果任務正在執行,若mayInterruptIfRunning設定為true,則返回true,若mayInterruptIfRunning設定為false,則返回false;如果任務還沒有執行,則無論mayInterruptIfRunning為true還是false,肯定返回true。
isCancelled 方法表示任務是否被取消成功,如果在任務正常完成前被取消成功,則返回 true。
isDone 方法表示任務是否已經完成,若任務完成,則返回true;
get() 方法用來獲取執行結果,這個方法會產生阻塞,會一直等到任務執行完畢才返回;
get(long timeout, TimeUnit unit) 用來獲取執行結果,如果在指定時間內,還沒獲取到結果,就直接返回null。
  也就是說Future提供了三種功能:

  1)判斷任務是否完成;

  2)能夠中斷任務;

  3)能夠獲取任務執行結果。

  因為Future只是一個介面,所以是無法直接用來建立物件使用的,因此就有了下面的FutureTask。

.FutureTask

public FutureTask(Callable<V> callable) {
}
public FutureTask(Runnable runnable, V result) {
}

我的程式碼 :

FutureTask + Callable

 public static void main(String[] args) throws ExecutionException, InterruptedException {
        Callable<String> callable = new
Callable<String>() { @Override public String call() throws Exception { System.out.println("執行緒啟動"+Thread.currentThread().getName()); return "aaa"; } }; FutureTask<String> ft = new FutureTask<String>(callable); new Thread(ft).start(); String s = ft.get(); System.out.println(s); }