openglobus/src/og/QueueArray.js

'use strict';

class QueueArray {
    constructor(size) {
        this._size = size || 2048;
        this._array = new Array(this._size);
        this._popIndex = parseInt(this._size * 0.5);
        this._shiftIndex = this._popIndex;
        this.length = 0;
    }

    reset() {
        this._popIndex = parseInt(this._size * 0.5);
        this._shiftIndex = this._popIndex;
        this.length = 0;
    }

    clear() {
        this._array.length = 0;
        this._array = new Array(this._size);
        this._popIndex = parseInt(this._size * 0.5);
        this._shiftIndex = this._popIndex;
        this.length = 0;
    }

    push(data) {
        this.length++;
        this._array[this._popIndex++] = data;
    }

    pop() {
        if (this.length) {
            this.length--;
            var res = this._array[--this._popIndex];
            this._array[this._popIndex] = null;
            if (!this._array[this._popIndex - 1]) {
                this._popIndex = parseInt(this._size * 0.5);
                this._shiftIndex = this._popIndex;
            }
            return res;
        }
        return undefined;
    }

    unshift(data) {
        this.length++;
        this._array[--this._shiftIndex] = data;
    }

    shift() {
        if (this.length) {
            this.length--;
            var res = this._array[this._shiftIndex];
            this._array[this._shiftIndex++] = null;
            if (!this._array[this._shiftIndex]) {
                this._popIndex = parseInt(this._size * 0.5);
                this._shiftIndex = this._popIndex;
            }
            return res;
        }
        return undefined;
    }

    each(callback) {
        for (var i = this._shiftIndex; i < this._popIndex; i++) {
            callback(this._array[i]);
        }
    }
};

export { QueueArray };