net.sergeych.tools

Class ByteRingBuffer

java.lang.Object

net.sergeych.tools.ByteRingBuffer

public class ByteRingBuffer
extends java.lang.Object

Efficient threadsafe blocking LIFO byte buffer. Created by sergeych on 13.04.16.

Constructor Summary

Constructors

Constructor and Description
ByteRingBuffer(int capacity)

Method Summary

Modifier and Type	Method and Description
int	get() Get the next byte, block until available.
byte[]	get(int size) Get several bytes from the queue (size can be any positive).
java.lang.String	getString(int size) Read bytes from the buffer, blocking untili available, and convert them to the UTF-8 string
boolean	isEmpty()
void	put(byte[] buffer) Put all the bytes to the buffer.
void	put(int value) put single byte.
<T extends java.lang.Number> void	put(java.lang.Iterable<T> collection) Put all the bytes to the buffer.
void	put(java.lang.String s) Put string in UTF-8 encoding into the buffer blocking until there is enough space.
int	read() Nonblocking get the next byte.
int	read(byte[] b) Nonblocking read.
byte[]	readAll() Get all data available from the buffer

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ByteRingBuffer

public ByteRingBuffer(int capacity)

Method Detail

get

public int get()

Get the next byte, block until available.

read

public int read()

Nonblocking get the next byte.

Returns:

-1 of there is no data or the next available byte.

put

public void put(int value)

put single byte. Block until the space is available.

Parameters:

value -

get

public byte[] get(int size)

Get several bytes from the queue (size can be any positive). Blocks until specified number of bytes are written.

put

public void put(byte[] buffer)

Put all the bytes to the buffer. Block until the operation is completed.

Parameters:

buffer -

put

public <T extends java.lang.Number> void put(java.lang.Iterable<T> collection)

Put all the bytes to the buffer. Blocks until the operation is completed.

Parameters:

collection -

getString

public java.lang.String getString(int size)

Read bytes from the buffer, blocking untili available, and convert them to the UTF-8 string

Parameters:

size - string exact size

put

public void put(java.lang.String s)

Put string in UTF-8 encoding into the buffer blocking until there is enough space.

Parameters:

s - string to put

isEmpty

public boolean isEmpty()

read

public int read(byte[] b)

Nonblocking read. Reads bytes into specified buffer

Parameters:

b - buffer to read into

Returns:

number of bytes read, 0 if the buffer is empty

readAll

public byte[] readAll()

Get all data available from the buffer

Returns: