Module org.apache.lucene.core

Package org.apache.lucene.index

Class DocumentsWriterFlushQueue

java.lang.Object

org.apache.lucene.index.DocumentsWriterFlushQueue

final class DocumentsWriterFlushQueue
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	DocumentsWriterFlushQueue.FlushTicket

Field Summary

Fields

Modifier and Type	Field	Description
private final ReentrantLock	purgeLock
private final Queue<DocumentsWriterFlushQueue.FlushTicket>	queue
private final AtomicInteger	ticketCount

Constructor Summary

Constructors

Constructor	Description
DocumentsWriterFlushQueue()

Method Summary

Modifier and Type	Method	Description
(package private) void	addSegment(DocumentsWriterFlushQueue.FlushTicket ticket, DocumentsWriterPerThread.FlushedSegment segment)
(package private) DocumentsWriterFlushQueue.FlushTicket	addTicket(Supplier<DocumentsWriterFlushQueue.FlushTicket> ticketSupplier)
private void	decTickets()
(package private) void	forcePurge(IOConsumer<DocumentsWriterFlushQueue.FlushTicket> consumer)
(package private) int	getTicketCount()
(package private) boolean	hasTickets()
private void	incTickets()
private void	innerPurge(IOConsumer<DocumentsWriterFlushQueue.FlushTicket> consumer)
(package private) void	markTicketFailed(DocumentsWriterFlushQueue.FlushTicket ticket)
(package private) void	tryPurge(IOConsumer<DocumentsWriterFlushQueue.FlushTicket> consumer)

Methods inherited from class java.lang.Object

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

Field Details

queue

private final Queue<DocumentsWriterFlushQueue.FlushTicket> queue

ticketCount

private final AtomicInteger ticketCount

purgeLock

private final ReentrantLock purgeLock

Constructor Details

DocumentsWriterFlushQueue

DocumentsWriterFlushQueue()

Method Details

addTicket

DocumentsWriterFlushQueue.FlushTicket addTicket(Supplier<DocumentsWriterFlushQueue.FlushTicket> ticketSupplier)
                                         throws IOException

Throws:

IOException

incTickets

private void incTickets()

decTickets

private void decTickets()

addSegment

void addSegment(DocumentsWriterFlushQueue.FlushTicket ticket,
 DocumentsWriterPerThread.FlushedSegment segment)

markTicketFailed

void markTicketFailed(DocumentsWriterFlushQueue.FlushTicket ticket)

hasTickets

boolean hasTickets()

innerPurge

private void innerPurge(IOConsumer<DocumentsWriterFlushQueue.FlushTicket> consumer)
                 throws IOException

Throws:

IOException

forcePurge

void forcePurge(IOConsumer<DocumentsWriterFlushQueue.FlushTicket> consumer)
         throws IOException

Throws:

IOException

tryPurge

void tryPurge(IOConsumer<DocumentsWriterFlushQueue.FlushTicket> consumer)
       throws IOException

Throws:

IOException

getTicketCount

int getTicketCount()