// 下面贴出来的是论文中讲到的FJTask有的方法,其余的一些辅助的方法也就不加进来了

private volatile boolean done; // = false;

public final boolean isDone() { return done; }

public static FJTaskRunner getFJTaskRunner() {
    return (FJTaskRunner)(Thread.currentThread());
}

public void fork() { getFJTaskRunner().push(this);  }

public void join() { getFJTaskRunner().taskJoin(this);  }

public static void coInvoke(FJTask task1, FJTask task2) {
    getFJTaskRunner().coInvoke(task1, task2);
}

/**
 * Push a task onto DEQ.
 * Called ONLY by current thread.
 **/

protected final void push(final FJTask r) {
  int t = top;

  /*
    This test catches both overflows and index wraps.  It doesn't
    really matter if base value is in the midst of changing in take. 
    As long as deq length is < 2^30, we are guaranteed to catch wrap in
    time since base can only be incremented at most length times
    between pushes (or puts). 
  */
  // 这里是重点,注释中也已经讲的很清楚了
  if (t < (base & (deq.length-1)) + deq.length) {

    deq[t & (deq.length-1)].put(r);
    top = t + 1;
  }

  else  // isolate slow case to increase chances push is inlined
    slowPush(r); // check overflow and retry
}

// slowPush主要是为了应对数组的resize
/**
 * Handle slow case for push
 **/

protected synchronized void slowPush(final FJTask r) {
  checkOverflow();
  push(r); // just recurse -- this one is sure to succeed.
}

/**
 * Return a popped task, or null if DEQ is empty.
 * Called ONLY by current thread.
 * <p>
 * This is not usually called directly but is
 * instead inlined in callers. This version differs from the
 * cilk algorithm in that pop does not fully back down and
 * retry in the case of potential conflict with take. It simply
 * rechecks under synch lock. This gives a preference
 * for threads to run their own tasks, which seems to
 * reduce flailing a bit when there are few tasks to run.
 **/

protected final FJTask pop() {
  /* 
     Decrement top, to force a contending take to back down.
  */

  int t = --top;      

  /*
    To avoid problems with JVMs that do not properly implement
    read-after-write of a pair of volatiles, we conservatively
    grab without lock only if the DEQ appears to have at least two
    elements, thus guaranteeing that both a pop and take will succeed,
    even if the pre-increment in take is not seen by current thread.
    Otherwise we recheck under synch.
  */

  if (base + 1 < t) 
    return deq[t & (deq.length-1)].take();
  else
    // 这就是论文中提到的pop失败之后会重试,直到队列真的为空
    return confirmPop(t);

}

/**
 * Check under synch lock if DEQ is really empty when doing pop. 
 * Return task if not empty, else null.
 **/

protected final synchronized FJTask confirmPop(int provisionalTop) {
  if (base <= provisionalTop) 
    return deq[provisionalTop & (deq.length-1)].take();
  else {    // was empty
    /*
      Reset DEQ indices to zero whenever it is empty.
      This both avoids unnecessary calls to checkOverflow
      in push, and helps keep the DEQ from accumulating garbage
    */

    top = base = 0;
    return null;
  }
}

/** 
 * Take a task from the base of the DEQ.
 * Always called by other threads via scan()
 **/


protected final synchronized FJTask take() {

  /*
    Increment base in order to suppress a contending pop
  */
  
  int b = base++;     
  
  if (b < top) 
    return confirmTake(b);
  else {
    // back out
    // take的机制就是类似于fail fast, 会去尝试窃取其他线程的taks
    base = b; 
    return null;
  }
}


/**
 * double-check a potential take
 **/

protected FJTask confirmTake(int oldBase) {

  /*
    Use a second (guaranteed uncontended) synch
    to serve as a barrier in case JVM does not
    properly process read-after-write of 2 volatiles
  */

  synchronized(barrier) {
    if (oldBase < top) {
      /*
        We cannot call deq[oldBase].take here because of possible races when
        nulling out versus concurrent push operations.  Resulting
        accumulated garbage is swept out periodically in
        checkOverflow, or more typically, just by keeping indices
        zero-based when found to be empty in pop, which keeps active
        region small and constantly overwritten. 
      */
      
      return deq[oldBase & (deq.length-1)].get();
    }
    else {
      base = oldBase;
      return null;
    }
  }
}

/** The threads in this group **/
protected final FJTaskRunner[] threads;

/** Group-wide queue for tasks entered via execute() **/
protected final LinkedQueue entryQueue = new LinkedQueue();

/** 
 * Create a FJTaskRunnerGroup with the indicated number
 * of FJTaskRunner threads. Normally, the best size to use is
 * the number of CPUs on the system. 
 * <p>
 * The threads in a FJTaskRunnerGroup are created with their
 * isDaemon status set, so do not normally need to be
 * shut down manually upon program termination.
 **/

public FJTaskRunnerGroup(int groupSize) { 
  threads = new FJTaskRunner[groupSize];
  initializeThreads();
  initTime = System.currentTimeMillis();
}

/**
 * Arrange for execution of the given task
 * by placing it in a work queue. If the argument
 * is not of type FJTask, it is embedded in a FJTask via 
 * <code>FJTask.Wrap</code>.
 * @exception InterruptedException if current Thread is
 * currently interrupted 
 **/

public void execute(Runnable r) throws InterruptedException {
  if (r instanceof FJTask) {
    entryQueue.put((FJTask)r);
  }
  else {
    entryQueue.put(new FJTask.Wrap(r));
  }
  signalNewTask();
}

// 1.类注解@PrepareForTest
@PrepareForTest(Static.class) // Static.class contains static methods
// 2.指定需要mock的静态方法
PowerMockito.mockStatic(Static.class);
// 3.使用Mockito接口来mock
// 在mock返回值为`void`的静态方法时可以使用`PowerMockito`的`when()`来进行mock
Mockito.when(Static.firstStaticMethod(param)).thenReturn(value);
// 4.校验mock结果
PowerMockito.verifyStatic(Static.class); // 1
Static.firstStaticMethod(param); // 2

// powermock
@RunWith(PowerMockRunner.class)
// 整合springtest
@PowerMockRunnerDelegate(SpringRunner.class)
// 排除java.security
@PowerMockIgnore( {"javax.management.*", "javax.net.ssl.*"})
// mock静态类注解
@PrepareForTest(Static.class)
// SpringBoot测试的注解
@SpringBootTest

import org.junit.*;
import org.junit.runner.*;
import org.springframework.beans.factory.annotation.*;
import org.springframework.boot.test.context.*;
import org.springframework.boot.test.mock.mockito.*;
import org.springframework.test.context.junit4.*;

import static org.assertj.core.api.Assertions.*;
import static org.mockito.BDDMockito.*;

@RunWith(SpringRunner.class)
@SpringBootTest
public class MyTests {

    @MockBean
    private RemoteService remoteService;

    @Autowired
    private Reverser reverser;

    @Test
    public void exampleTest() {
        // RemoteService has been injected into the reverser bean
        given(this.remoteService.someCall()).willReturn("mock");
        String reverse = reverser.reverseSomeCall();
        assertThat(reverse).isEqualTo("kcom");
    }

}

import org.junit.jupiter.api.Test;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.web.servlet.MockMvc;

import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.get;
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.content;
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;

@SpringBootTest
@AutoConfigureMockMvc
class MockMvcExampleTests {

    @Test
    void exampleTest(@Autowired MockMvc mvc) throws Exception {
        mvc.perform(get("/")).andExpect(status().isOk()).andExpect(content().string("Hello World"));
    }

}

import org.junit.*;
import org.junit.runner.*;
import org.springframework.beans.factory.annotation.*;
import org.springframework.boot.test.autoconfigure.web.servlet.*;
import org.springframework.boot.test.mock.mockito.*;

import static org.assertj.core.api.Assertions.*;
import static org.mockito.BDDMockito.*;
import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.*;
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.*;

@RunWith(SpringRunner.class)
@WebMvcTest(UserVehicleController.class)
public class MyControllerTests {

    @Autowired
    private MockMvc mvc;

    @MockBean
    private UserVehicleService userVehicleService;

    @Test
    public void testExample() throws Exception {
        given(this.userVehicleService.getVehicleDetails("sboot"))
                .willReturn(new VehicleDetails("Honda", "Civic"));
        this.mvc.perform(get("/sboot/vehicle").accept(MediaType.TEXT_PLAIN))
                .andExpect(status().isOk()).andExpect(content().string("Honda Civic"));
    }

}