public class FutureTest {
? ? public static void main(String[] args) throws ExecutionException, InterruptedException {
? ? ? ? MyThread myThread = new MyThread();
? ? ? ? FutureTask<String> futureTask = new FutureTask<>(myThread);
? ? ? ? /**
? ? ? ? ?* 同一個(gè)futureTask對象，通過多個(gè)線程進(jìn)行多次調(diào)用，但是只會(huì)執(zhí)行一次
? ? ? ? ?* 如果是計(jì)算的操作，需要進(jìn)行多次計(jì)算操作，需要聲明不同的futureTask對象
? ? ? ? ?*/
? ? ? ? new Thread(futureTask, "A").start();
? ? ? ? new Thread(futureTask, "B").start();
? ? ? ? System.out.println(Thread.currentThread().getName() + "測試，在調(diào)用future.get()方法之前，可以執(zhí)行其他邏輯 ");
? ? ? ? System.out.println(futureTask.get());
? ? ? ? System.out.println("測試futureTask的get方法阻塞");
? ? }
}

class MyThread implements Callable<String> {

? ? @Override
? ? public String call() throws Exception {
? ? ? ? System.out.println(Thread.currentThread().getName() + " 測試callable");
? ? ? ? TimeUnit.SECONDS.sleep(4);
? ? ? ? return "success";
? ? }
}

private volatile int state;
? ? /**
? ? ?* 在構(gòu)造函數(shù)中，設(shè)置為new
? ? ?*/
? ? private static final int NEW ? ? ? ? ?= 0;
? ? /**
? ? ?* 線程正常執(zhí)行完畢，通過CAS將state修改為completing
? ? ?*/
? ? private static final int COMPLETING ? = 1;
? ? /**
? ? ?*
? ? ?*/
? ? private static final int NORMAL ? ? ? = 2;
? ? /**
? ? ?* 執(zhí)行線程的時(shí)候，如果拋出異常，通過cas修改為exceptional
? ? ?*/
? ? private static final int EXCEPTIONAL ?= 3;
? ? /**
? ? ?* 如果調(diào)用了cancel(boolean mayInterruptIfRunning)方法
? ? ?* 入?yún)⒌膍ayInterruptIfRunning為true，就通過cas將state設(shè)置為INTERRUPTING
? ? ?* 如果為false，就通過cas將state修改為cancelled
? ? ?*/
? ? private static final int CANCELLED ? ?= 4;
? ? private static final int INTERRUPTING = 5;
? ? /**
? ? ?* 在調(diào)用cancel()方法，入?yún)閠rue的情況下，如果中斷成功，通過cas將state從
? ? ?* INTERRUPTING修改為INTERRUPTED
? ? ?*/
? ? private static final int INTERRUPTED ?= 6;

/**
? ? ?* @throws CancellationException {@inheritDoc}
? ? ?* 在調(diào)用future.get()方法的時(shí)候，如果線程的run()沒有執(zhí)行完畢，主線程會(huì)等待，直到run()方法正確的執(zhí)行完畢
? ? ?* 在內(nèi)部，是通過lockSupport.park()方法去阻塞線程的
? ? ?* 在該機(jī)制中，涉及到一個(gè)state狀態(tài)標(biāo)識
? ? ?*/
? ? public V get() throws InterruptedException, ExecutionException {
? ? ? ? int s = state;
? ? ? ? if (s <= COMPLETING)
? ? ? ? ? ? s = awaitDone(false, 0L);
? ? ? ? return report(s);
? ? }

public void run() {
? ? ? ? /**
? ? ? ? ?* 1.校驗(yàn)當(dāng)前state是否是new狀態(tài)且通過cas設(shè)置當(dāng)前線程成功
? ? ? ? ?*/
? ? ? ? if (state != NEW ||
? ? ? ? ? ? !UNSAFE.compareAndSwapObject(this, runnerOffset,
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?null, Thread.currentThread()))
? ? ? ? ? ? return;
? ? ? ? try {
? ? ? ? ? ? Callable<V> c = callable;
? ? ? ? ? ? /**
? ? ? ? ? ? ?* 2.校驗(yàn)當(dāng)前線程中的callable是否有效且state為new
? ? ? ? ? ? ?*/
? ? ? ? ? ? if (c != null && state == NEW) {
? ? ? ? ? ? ? ? V result;
? ? ? ? ? ? ? ? boolean ran;
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? /**
? ? ? ? ? ? ? ? ? ? ?* 2.1 執(zhí)行call()方法，如果正常執(zhí)行完畢，設(shè)置ran為true
? ? ? ? ? ? ? ? ? ? ? */
? ? ? ? ? ? ? ? ? ? result = c.call();
? ? ? ? ? ? ? ? ? ? ran = true;
? ? ? ? ? ? ? ? } catch (Throwable ex) {
? ? ? ? ? ? ? ? ? ? result = null;
? ? ? ? ? ? ? ? ? ? ran = false;
? ? ? ? ? ? ? ? ? ? /**
? ? ? ? ? ? ? ? ? ? ?* 2.2 假如執(zhí)行報(bào)錯(cuò)，被捕獲到，在setException方法中，也會(huì)去喚醒阻塞的線程
? ? ? ? ? ? ? ? ? ? ?*/
? ? ? ? ? ? ? ? ? ? setException(ex);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? /**
? ? ? ? ? ? ? ? ?* 3.如果ran為true，就調(diào)用set方法，在set方法中，有一步跟重要的操作，就是通過lockSupport.unpark()喚醒線程
? ? ? ? ? ? ? ? ?*/
? ? ? ? ? ? ? ? if (ran)
? ? ? ? ? ? ? ? ? ? set(result);
? ? ? ? ? ? }
? ? ? ? } finally {
? ? ? ? ? ? // runner must be non-null until state is settled to
? ? ? ? ? ? // prevent concurrent calls to run()
? ? ? ? ? ? runner = null;
? ? ? ? ? ? // state must be re-read after nulling runner to prevent
? ? ? ? ? ? // leaked interrupts
? ? ? ? ? ? int s = state;
? ? ? ? ? ? if (s >= INTERRUPTING)
? ? ? ? ? ? ? ? handlePossibleCancellationInterrupt(s);
? ? ? ? }
? ? }

?? ?/*
?? ?* 在set方法中，會(huì)通過cas更新當(dāng)前的state狀態(tài)
? ? ?* 然后在調(diào)用finishCompletion的時(shí)候，會(huì)喚醒阻塞的線程
? ? ?* @param v the value
? ? ?*/
? ? protected void set(V v) {
? ? ? ? if (UNSAFE.compareAndSwapInt(this, stateOffset, NEW, COMPLETING)) {
? ? ? ? ? ? outcome = v;
? ? ? ? ? ? UNSAFE.putOrderedInt(this, stateOffset, NORMAL); // final state
? ? ? ? ? ? finishCompletion();
? ? ? ? }
? ? }

/**
? ? ?* Removes and signals all waiting threads, invokes done(), and
? ? ?* nulls out callable.
? ? ?* 這個(gè)方法大致的意思是：從等待隊(duì)列中獲取到當(dāng)前在等待的線程信息，然后通過cas將q設(shè)置為null
? ? ?* 最后會(huì)通過lockSupport.unPark()方法喚醒線程
? ? ?*/
? ? private void finishCompletion() {
? ? ? ? // assert state > COMPLETING;
? ? ? ? /**
? ? ? ? ?* 1.從waiters中獲取到等待的節(jié)點(diǎn)
? ? ? ? ?*/
? ? ? ? for (WaitNode q; (q = waiters) != null;) {
? ? ? ? ? ? /**
? ? ? ? ? ? ?* 2.通過cas將q設(shè)置為null
? ? ? ? ? ? ?*/
? ? ? ? ? ? if (UNSAFE.compareAndSwapObject(this, waitersOffset, q, null)) {
? ? ? ? ? ? ? ? for (;;) {
? ? ? ? ? ? ? ? ? ? Thread t = q.thread;
? ? ? ? ? ? ? ? ? ? /**
? ? ? ? ? ? ? ? ? ? ?* 3.喚醒線程
? ? ? ? ? ? ? ? ? ? ?*/
? ? ? ? ? ? ? ? ? ? if (t != null) {
? ? ? ? ? ? ? ? ? ? ? ? q.thread = null;
? ? ? ? ? ? ? ? ? ? ? ? LockSupport.unpark(t);
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? WaitNode next = q.next;
? ? ? ? ? ? ? ? ? ? if (next == null)
? ? ? ? ? ? ? ? ? ? ? ? break;
? ? ? ? ? ? ? ? ? ? q.next = null; // unlink to help gc
? ? ? ? ? ? ? ? ? ? q = next;
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? break;
? ? ? ? ? ? }
? ? ? ? }

? ? ? ? done();

? ? ? ? callable = null; ? ? ? ?// to reduce footprint
? ? }