Java 类org.apache.commons.collections4.queue.CircularFifoQueue 实例源码

项目：BittrexGatherer 文件：BittrexPriceVerticle.java

public BittrexPriceVerticle(OrderFillService service){
    super();
    service = service;
    indicators = new IndicatorDTO();
    cachedTicks = new CircularFifoQueue<MarketTick>(20);
    SimpleMovingAverage ma_1 = new SimpleMovingAverage(20, "ma_1");
    BollingerBands bb_1 = new BollingerBands(ma_1, 2);
    VolumeWeightedMovingAverage vwma_1 = new VolumeWeightedMovingAverage(20, "vwma_1");
    RSI rsi_1 = new RSI(14, "rsi_1");
    currentTick = new MarketTick();

    indicators.setBb(bb_1);
    indicators.setRsi(rsi_1);
    indicators.setSma(ma_1);
    indicators.setVwma(vwma_1);
    timerInterval = 5*60*1000;

}

项目：stallion-core 文件：HealthTracker.java

public void incrementQueue(CircularFifoQueue<MinuteInfo> queue) {
    ZonedDateTime now = MinuteInfo.getCurrentMinute();
    MinuteInfo minuteInfo = null;
    if (!queue.isEmpty()) {
        minuteInfo = queue.get(queue.size()-1);
        //minuteInfo = queue.get(0);
        //Log.info("first: {0}", queue.get(0).getMinute());
        //Log.info("last:  {0}", queue.get(queue.size() -1).getMinute());
        //Log.info("now:   {0}", now);
        if (!minuteInfo.getMinute().equals(now)) {
            //Log.info("Minutes do not matched, prepare for new minute");
            minuteInfo = null;
        }
    }
    if (minuteInfo == null) {
        minuteInfo = new MinuteInfo();
        minuteInfo.setMinute(now);
        queue.add(minuteInfo);
    }
    //Log.info("Increment minute {0} {1}", minuteInfo.getMinute().toString(), minuteInfo.getCount().get());
    minuteInfo.getCount().incrementAndGet();
}

项目：panopticon 文件：SuccessrateSensor.java

@Override
public List<Measurement> measure() {
    return eventQueues.entrySet().stream()
            .map((Map.Entry<String, CircularFifoQueue<Event>> e) -> {
                List<Event> events = e.getValue().stream().collect(toList());
                int all = events.size();
                long success = events.stream().filter(a -> a == Event.SUCCESS).count();
                long failure = events.stream().filter(a -> a == Event.FAILURE).count();
                double percentFailureDouble = all > 0 ? (double) failure / (double) all : 0;
                boolean enoughDataToAlert = all == numberToKeep;
                String display = String.format("Last %s calls: %s success, %s failure (%.2f%% failure)%s",
                        Integer.min(all, numberToKeep),
                        success,
                        all-success,
                        percentFailureDouble * 100,
                        enoughDataToAlert ? "" : " - not enough calls to report status yet"
                );
                return new Measurement(e.getKey(), getStatusFromPercentage(enoughDataToAlert, percentFailureDouble), display, new Measurement.CloudwatchValue(percentFailureDouble * 100, StandardUnit.Percent));
            })
            .collect(toList());
}

项目：jfastnet 文件：AbstractTest.java

public Message getLastReceivedMessageFromLog(CircularFifoQueue<Message> received, boolean ignoreSystemMessages, Class type) {
    if (received.size() == 0) {
        return null;
    }
    for (int i = received.size() - 1; i >= 0; i--) {
        Message message = received.get(i);
        if (type != null) {
            if (!type.isAssignableFrom(message.getClass())) {
                continue;
            }
        } else if (ignoreSystemMessages) {
            if (message instanceof SequenceKeepAlive) continue;
            if (message instanceof AckMessage) continue;
            if (message instanceof ConnectResponse) continue;
            if (message instanceof RequestSeqIdsMessage) continue;
            if (message instanceof StackedMessage) continue;
        }
        return message;
    }
    // If all are system messages, return the last
    return received.get(received.size() - 1);
}

项目：jfastnet 文件：AbstractTest.java

public List<Message> getLastReceivedMessagesFromLog(Class type) {
    List<Message> messages = new ArrayList<>();
    CircularFifoQueue<Message> received = server.getState().getProcessorOf(MessageLogProcessor.class).getMessageLog().getReceived();
    if (received.size() == 0) {
        return null;
    }
    for (int i = received.size() - 1; i >= 0; i--) {
        Message message = received.get(i);
        if (type != null) {
            if (type.isAssignableFrom(message.getClass())) {
                messages.add(message);
            }
        }
    }
    return messages;
}

项目：Blaubot 文件：BeaconView.java

private void initView(Context context, AttributeSet attrs) {
    this.mContext = context;
    if (attrs != null) {
        TypedArray a = context.getTheme().obtainStyledAttributes(
                attrs,
                R.styleable.LifeCycleView,
                0, 0);
        try {
            mMaxEvents = a.getInt(R.styleable.BeaconView_maxEvents, mMaxEvents);
        } finally {
            a.recycle();
        }
    }
    this.lastEvents = new CircularFifoQueue<>();
    mUiHandler = new Handler(Looper.getMainLooper());
}