TrampolineScheduler.java 文件源码

private InnerCurrentThreadScheduler() {
    this.counter = new AtomicInteger();
    this.queue = new PriorityBlockingQueue();
    this.innerSubscription = new BooleanSubscription();
    this.wip = new AtomicInteger();
}