SeqObserverQueue.java 文件源码

private void init(BlockingQueue<Callable> tBlockingQeque, int wait){
    tBlockingDeque = tBlockingQeque;
    mExecutorService = Executors.newSingleThreadExecutor();
    mBusy = new AtomicBoolean(false);
    observers = new ConcurrentLinkedQueue<>();
    changed = false;
    mWAIT = wait;
}