trinity.buffer.writer.queue_writer module

trinity.buffer.writer.queue_writer module#

Writer of the Queue buffer.

class trinity.buffer.writer.queue_writer.QueueWriter(config: StorageConfig)[source]#

Bases: BufferWriter

Writer of the Queue buffer.

__init__(config: StorageConfig)[source]#
write(data: List[Experience]) → None[source]#

Write to buffer.

async write_async(data: List[Experience]) → None[source]#

Write to buffer asynchronously.

async acquire() → int[source]#

Acquire the buffer writer.

Returns:

The reference count of the buffer after acquiring.

Return type:

int

async release() → int[source]#

Release the buffer writer. After release, the buffer writer can not be used again.

Returns:

The reference count of the buffer after releasing.

Return type:

int