Class BoundedBuffer.RingBuffer<E>

java.lang.Object

com.github.benmanes.caffeine.cache.BBHeader.PadReadCounter

com.github.benmanes.caffeine.cache.BBHeader.ReadCounterRef

com.github.benmanes.caffeine.cache.BBHeader.PadWriteCounter

com.github.benmanes.caffeine.cache.BBHeader.ReadAndWriteCounterRef

com.github.benmanes.caffeine.cache.BoundedBuffer.RingBuffer<E>

All Implemented Interfaces:

Buffer<E>

Enclosing class:

BoundedBuffer<E>

static final class BoundedBuffer.RingBuffer<E>
extends BBHeader.ReadAndWriteCounterRef
implements Buffer<E>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final AtomicReferenceArray<E>	buffer

Fields inherited from class BBHeader.ReadAndWriteCounterRef

WRITE_OFFSET, writeCounter

Fields inherited from class BBHeader.PadWriteCounter

p120, p121, p122, p123, p124, p125, p126, p127, p128, p129, p130, p131, p132, p133, p134, p135, p136, p137, p138, p139, p140, p141, p142, p143, p144, p145, p146, p147, p148, p149, p150, p151, p152, p153, p154, p155, p156, p157, p158, p159, p160, p161, p162, p163, p164, p165, p166, p167, p168, p169, p170, p171, p172, p173, p174, p175, p176, p177, p178, p179, p180, p181, p182, p183, p184, p185, p186, p187, p188, p189, p190, p191, p192, p193, p194, p195, p196, p197, p198, p199, p200, p201, p202, p203, p204, p205, p206, p207, p208, p209, p210, p211, p212, p213, p214, p215, p216, p217, p218, p219, p220, p221, p222, p223, p224, p225, p226, p227, p228, p229, p230, p231, p232, p233, p234, p235, p236, p237, p238, p239

Fields inherited from class BBHeader.ReadCounterRef

READ_OFFSET, readCounter

Fields inherited from class BBHeader.PadReadCounter

p000, p001, p002, p003, p004, p005, p006, p007, p008, p009, p010, p011, p012, p013, p014, p015, p016, p017, p018, p019, p020, p021, p022, p023, p024, p025, p026, p027, p028, p029, p030, p031, p032, p033, p034, p035, p036, p037, p038, p039, p040, p041, p042, p043, p044, p045, p046, p047, p048, p049, p050, p051, p052, p053, p054, p055, p056, p057, p058, p059, p060, p061, p062, p063, p064, p065, p066, p067, p068, p069, p070, p071, p072, p073, p074, p075, p076, p077, p078, p079, p080, p081, p082, p083, p084, p085, p086, p087, p088, p089, p090, p091, p092, p093, p094, p095, p096, p097, p098, p099, p100, p101, p102, p103, p104, p105, p106, p107, p108, p109, p110, p111, p112, p113, p114, p115, p116, p117, p118, p119

Fields inherited from interface Buffer

FAILED, FULL, SUCCESS

Constructor Summary

Constructors

Constructor	Description
RingBuffer(E e)

Method Summary

Modifier and Type	Method	Description
void	drainTo(Consumer<E> consumer)	Drains the buffer, sending each element to the consumer for processing.
int	offer(E e)	Inserts the specified element into this buffer if it is possible to do so immediately without violating capacity restrictions.
int	reads()	Returns the number of elements that have been read from the buffer.
int	writes()	Returns the number of elements that have been written to the buffer.

Methods inherited from class BBHeader.ReadAndWriteCounterRef

casWriteCounter, relaxedWriteCounter

Methods inherited from class BBHeader.ReadCounterRef

lazySetReadCounter

Methods inherited from class Object

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

Methods inherited from interface Buffer

size

Field Details

buffer

final AtomicReferenceArray<E> buffer

Constructor Details

RingBuffer

public RingBuffer(E e)

Method Details

offer

public int offer(E e)

Description copied from interface: Buffer

Inserts the specified element into this buffer if it is possible to do so immediately without violating capacity restrictions. The addition is allowed to fail spuriously if multiple threads insert concurrently.

Specified by:

offer in interface Buffer<E>

Parameters:

e - the element to add

Returns:

1 if the buffer is full, -1 if the CAS failed, or 0 if added

drainTo

public void drainTo(Consumer<E> consumer)

Description copied from interface: Buffer

Drains the buffer, sending each element to the consumer for processing. The caller must ensure that a consumer has exclusive read access to the buffer.

Specified by:

drainTo in interface Buffer<E>

Parameters:

consumer - the action to perform on each element

reads

public int reads()

Description copied from interface: Buffer

Returns the number of elements that have been read from the buffer.

Specified by:

reads in interface Buffer<E>

Returns:

the number of elements read from this buffer

writes

public int writes()

Description copied from interface: Buffer

Returns the number of elements that have been written to the buffer.

Specified by:

writes in interface Buffer<E>

Returns:

the number of elements written to this buffer