public class Test {
    //計(jì)算結(jié)果
    int count=0;
    @Test
    public void test(){
        try{  
            FutureTask<Integer> futureTask=new FutureTask<>(new Callable<Integer>() {
                @Override
                public Integer call() throws Exception {
                    return 1;
                }
            });
            //把FutureTask放入線程中,線程會(huì)運(yùn)行FutureTask的run()代碼塊
            Thread t1=new Thread(futureTask);
            t1.start();
            //獲取計(jì)算的結(jié)果,是一個(gè)阻塞等待返回的方法
            count+=futureTask.get();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
        //最后結(jié)果: 1
        System.out.println(count);    
    }
}

/**
    執(zhí)行結(jié)果(全局變量), 有2種情況:
    1. 順利完成返回的結(jié)果
    2. 執(zhí)行run()代碼塊過(guò)程中拋出的異常
*/
private Object outcome; 
//正在執(zhí)行run()的線程, 內(nèi)存可被其他線程可見(jiàn)
private volatile Thread runner;
???????public void run() {
    /**
        FutureTask的run()僅執(zhí)行一次的原因：
        1. state != NEW表示任務(wù)正在被執(zhí)行或已經(jīng)完成, 直接return
        2. 若state==NEW, 則嘗試CAS將當(dāng)前線程 設(shè)置為執(zhí)行run()的線程,如果失敗,說(shuō)明已經(jīng)有其他線程 先行一步執(zhí)行了run(),則當(dāng)前線程return退出
    */
    if (state != NEW ||!UNSAFE.compareAndSwapObject(this, runnerOffset,null, Thread.currentThread()))
        return;
    try {
        //持有Callable的實(shí)例,后續(xù)會(huì)執(zhí)行該實(shí)例的call()方法
        Callable<V> c = callable;
        if (c != null && state == NEW) {
            V result;
            boolean ran;
            try {
                result = c.call();
                ran = true;
            }catch (Throwable ex) {
                result = null;
                ran = false;
                //執(zhí)行中拋的異常會(huì)放入outcome中保存
                setException(ex);
            }
            if (ran)
                //若無(wú)異常, 順利完成的執(zhí)行結(jié)果會(huì)放入outcome保存
                set(result);
        }
    }finally {
        // help GC 
        runner = null;
        int s = state;
        if (s >= INTERRUPTING)
            handlePossibleCancellationInterrupt(s);
    }
}

public V get() throws InterruptedException, ExecutionException {    
       int s = state;
       //COMPLETING: 正在完成的狀態(tài);  s <= COMPLETING就是未完成
    if (s <= COMPLETING)
        //不計(jì)時(shí)等待,結(jié)束等待的條件只有【完成】、【被中斷】、【被取消】、【拋其他異常(不包括中斷異常、取消異常)】
        s = awaitDone(false, 0L);
    return report(s);    
}

private volatile int state;
//線程創(chuàng)建狀態(tài)
private static final int NEW = 0;
//完成(**一個(gè)瞬時(shí)的標(biāo)記**)   
private static final int COMPLETING = 1;
//正常完成狀態(tài)
private static final int NORMAL = 2;
//執(zhí)行過(guò)程出現(xiàn)異常
private static final int EXCEPTIONAL = 3;
//執(zhí)行過(guò)程中被取消
private static final int CANCELLED = 4;
//線程執(zhí)行被中斷(**一個(gè)瞬時(shí)的標(biāo)記**)
private static final int INTERRUPTING = 5;
//線程執(zhí)行被中斷的狀態(tài)
private static final int INTERRUPTED = 6;

/**
    @param timed 若是true則為定時(shí)等待,超時(shí)后會(huì)結(jié)束等待,并返回當(dāng)前狀態(tài)state
    @param nanos 如果是定時(shí)等待即第一個(gè)入?yún)imed=true的話,會(huì)設(shè)置對(duì)應(yīng)的等待時(shí)長(zhǎng)
*/
private int awaitDone(boolean timed, long nanos) throws InterruptedException {
    //等待的最后期限
    final long deadline = timed ? System.nanoTime() + nanos : 0L;
    WaitNode q = null;
    boolean queued = false;
    //進(jìn)入無(wú)限循環(huán)的等待狀態(tài),只有【完成】、【被取消】、【異?！?、【中斷】、【超時(shí)】這五種情況才會(huì)結(jié)束等待
    for (;;) {
        if (Thread.interrupted()) {
            //線程執(zhí)行被中斷,則移除等待結(jié)點(diǎn)并拋出異常
            removeWaiter(q);
            throw new InterruptedException();
        }
         int s = state;
        //【完成】、【被取消】、【拋其他異?！康臓顟B(tài)都會(huì) 在這 結(jié)束等待
        if (s > COMPLETING) {
            if (q != null)
                q.thread = null;
            return s;
        }
        //子線程處于任務(wù)完成的瞬時(shí)狀態(tài),要等一會(huì)才能拿到執(zhí)行結(jié)果
        else if (s == COMPLETING) // cannot time out yet
            Thread.yield();
        else if (q == null)
            q = new WaitNode();
        else if (!queued)
            queued = UNSAFE.compareAndSwapObject(this, waitersOffset, q.next = waiters, q);
        else if (timed) {
            //設(shè)置定時(shí)等待并且已經(jīng)超時(shí)了
            nanos = deadline - System.nanoTime();
            if (nanos <= 0L) {
                removeWaiter(q);
                return state;
            }
            LockSupport.parkNanos(this, nanos);
        }
        else
            LockSupport.park(this);       
    }
}

/*正常的計(jì)算結(jié)果 or 拋出的異常 都會(huì)作為outcome*/
private Object outcome;
private V report(int s) throws ExecutionException {
    Object x = outcome;
    //正常完成
    if (s == NORMAL)
        return (V)x;
    //執(zhí)行的過(guò)程中【被取消】
    if (s >= CANCELLED)
        throw new CancellationException();
    /**
        這里拋的是執(zhí)行過(guò)程中發(fā)生的其他異常,既不是【中斷異常】,也不是【被取消異?！?
        比如發(fā)生了RuntimeException之類(lèi)的就會(huì)在這拋
    */    
    throw new ExecutionException((Throwable)x);
}

public class FutureTask<V> implements RunnableFuture<V> {
    //執(zhí)行任務(wù)并返回結(jié)果
    private Callable<V> callable;
    public FutureTask(Callable<V> callable) {
        if (callable == null)
            throw new NullPointerException();
        this.callable = callable;
        //新建狀態(tài)
        this.state = NEW;
    }
}