Package adaptlil.buffer

Class AsyncBuffer<T>

java.lang.Object

adaptlil.buffer.AsyncBuffer<T>

Type Parameters:

T -

public class AsyncBuffer<T>
extends Object

Generically typed buffer that supports Asynchronous operations.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final LinkedList<T>	dataQueue
private ReentrantLock	reentrantLock

Constructor Summary

Constructors

Constructor	Description
AsyncBuffer()

Method Summary

Modifier and Type	Method	Description
void	flush()	Flush the queue
boolean	isEmpty()
T	read()	Blocks the main thread from reading until the lock is released.
int	size()
void	write(T data)	Uses and entrant lock and blocks the main thread from writing until the lock is released

Methods inherited from class java.lang.Object

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

Field Details

dataQueue

final LinkedList<T> dataQueue

reentrantLock

private ReentrantLock reentrantLock

Constructor Details

AsyncBuffer

public AsyncBuffer()

Method Details

write

public void write(T data)

Uses and entrant lock and blocks the main thread from writing until the lock is released

Parameters:

data -

read

public T read()

Blocks the main thread from reading until the lock is released.

Returns:

flush

public void flush()

Flush the queue

size

public int size()

isEmpty

public boolean isEmpty()