xyz.cofe.text

Class TextBuffer

java.lang.Object

java.io.Reader

xyz.cofe.text.TextBuffer

All Implemented Interfaces:

Closeable, AutoCloseable, Readable

public class TextBuffer
extends Reader

Синхронный текстовый буфер для потоковых операций: Reader / Writer.

Операции чтения (read()) выставляют флаг ожидания waitData и будет ждать появления данных в буфере, переодично опрашивая содержимое буфера.
Данные буфера чиаются с начала, и прочитанные данные удаляются из буфера.

Операции записи (write()) временно блокирует буфер для записи данных в конец буфера.

Author:

nt.gocha@gmail.com

Field Summary

Fields

Modifier and Type	Field and Description
protected StringBuilder	buffer
protected Object	bufferLock
protected Random	rnd
protected AtomicBoolean	waitData
protected Writer	writer

Fields inherited from class java.io.Reader

lock

Constructor Summary

Constructors

Constructor and Description
TextBuffer()
TextBuffer(StringBuilder buffer)
TextBuffer(StringBuilder buffer, Object bufferLock)

Method Summary

Modifier and Type	Method and Description
void	close() Закрывает буфер
Writer	createWriter()
StringBuilder	getBuffer() Буфер
Object	getBufferLock() Объект для блокировки чтения/записи содержимого буфера
String	getBufferText() Синхронно читает содержимое буфера
Writer	getWriter()
boolean	isWaitData() Возвращает флаг ожидания данных в буфере, т.е. в данный момент выполняется операция read()
int	read(char[] cbuf, int off, int len) Синхронно читает данные из буфера
void	write(String txt) Синхронно записывает данные в конец буфера

Methods inherited from class java.io.Reader

mark, markSupported, read, read, read, ready, reset, skip

Methods inherited from class java.lang.Object

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

Field Detail

buffer

protected StringBuilder buffer

rnd

protected final Random rnd

bufferLock

protected final Object bufferLock

waitData

protected final AtomicBoolean waitData

writer

protected volatile Writer writer

Constructor Detail

TextBuffer

public TextBuffer(StringBuilder buffer)

TextBuffer

public TextBuffer(StringBuilder buffer,
                  Object bufferLock)

TextBuffer

public TextBuffer()

Method Detail

getBuffer

public StringBuilder getBuffer()

Буфер

Returns:

буфер

getBufferLock

public Object getBufferLock()

Объект для блокировки чтения/записи содержимого буфера

Returns:

объект блокировки

getBufferText

public String getBufferText()

Синхронно читает содержимое буфера

Returns:

содержимое буфера

isWaitData

public boolean isWaitData()

Возвращает флаг ожидания данных в буфере, т.е. в данный момент выполняется операция read()

Returns:

флаг ожидания данных

read

public int read(char[] cbuf,
                int off,
                int len)
         throws IOException

Синхронно читает данные из буфера

Specified by:

read in class Reader

Parameters:

cbuf - приемник

off - смещение

len - длинна

Returns:

сколько прочитано

Throws:

IOException - ошибка чтения

close

public void close()
           throws IOException

Закрывает буфер

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in class Reader

Throws:

IOException - Ошибка IO

write

public void write(String txt)

Синхронно записывает данные в конец буфера

Parameters:

txt - данные

createWriter

public Writer createWriter()

getWriter

public Writer getWriter()