X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcircular-buffer.ts;h=55f5f9bfc22e48f6f6e42da61c252ec124ac0bca;hb=eadb37e247acfa716cad2a1e211c947513c251bf;hp=2975ef7797389b2cb370c0184de493c81fe85ed7;hpb=12c589b6bbb06466d2168e4867ff51c4b45d3bd3;p=poolifier.git diff --git a/src/circular-buffer.ts b/src/circular-buffer.ts index 2975ef77..55f5f9bf 100644 --- a/src/circular-buffer.ts +++ b/src/circular-buffer.ts @@ -4,17 +4,15 @@ export const defaultBufferSize = 2048 /** - * Circular buffer. + * Circular buffer designed for positive numbers. * - * @typeParam T - Type of buffer data. * @internal */ -export class CircularBuffer { +export class CircularBuffer { private readIdx: number private writeIdx: number - private items: Array + private items: Float32Array private readonly maxArrayIdx: number - /* Buffer number of elements */ public size: number /** @@ -27,7 +25,7 @@ export class CircularBuffer { this.writeIdx = 0 this.maxArrayIdx = size - 1 this.size = 0 - this.items = new Array(size) + this.items = new Float32Array(size).fill(-1) } /** @@ -49,12 +47,12 @@ export class CircularBuffer { } /** - * Puts data into buffer. + * Puts number into buffer. * - * @param data - Data to put into buffer. + * @param number - Number to put into buffer. */ - public put (data: T): void { - this.items[this.writeIdx] = data + public put (number: number): void { + this.items[this.writeIdx] = number this.writeIdx = this.writeIdx === this.maxArrayIdx ? 0 : this.writeIdx + 1 if (this.size < this.items.length) { ++this.size @@ -62,28 +60,28 @@ export class CircularBuffer { } /** - * Gets data from buffer. + * Gets number from buffer. * - * @returns Data from buffer. + * @returns Number from buffer. */ - public get (): T | undefined { - const data = this.items[this.readIdx] - if (data == null) { + public get (): number | undefined { + const number = this.items[this.readIdx] + if (number === -1) { return } - this.items[this.readIdx] = undefined + this.items[this.readIdx] = -1 this.readIdx = this.readIdx === this.maxArrayIdx ? 0 : this.readIdx + 1 --this.size - return data + return number } /** - * Returns buffer as array. + * Returns buffer as numbers' array. * - * @returns Array of buffer data. + * @returns Numbers' array. */ - public toArray (): T[] { - return this.items.filter(item => item != null) as T[] + public toArray (): number[] { + return Array.from(this.items.filter(item => item !== -1)) } private checkSize (size: number): void {