net.yacy.peers

Class Protocol.WriteToLocalIndexThread

java.lang.Object

java.lang.Thread

net.yacy.peers.Protocol.WriteToLocalIndexThread

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

Protocol

private static class Protocol.WriteToLocalIndexThread
extends java.lang.Thread

This thread is used to write a collection of Solr documents to a segment allowing to be safely stopped. Indeed, if one interrupt a thread while commiting to Solr index, the index is closed and will be no more writable (later calls would throw a org.apache.lucene.store.AlreadyClosedException) because Solr IndexWriter uses an InterruptibleChanel. This thead allow to safely stop writing operation using an AtomicBoolean.

Author:

luc

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Collection<SolrInputDocument>	docs
private Segment	segment
private java.util.concurrent.atomic.AtomicBoolean	stop

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
Protocol.WriteToLocalIndexThread(Segment segment, java.util.Collection<SolrInputDocument> docs) Parameters must be not null.

Method Summary

Methods

Modifier and Type	Method and Description
void	run()
void	stopWriting() Use this to stop writing operation.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

stop

private java.util.concurrent.atomic.AtomicBoolean stop

segment

private Segment segment

docs

private java.util.Collection<SolrInputDocument> docs

Constructor Detail

Protocol.WriteToLocalIndexThread

public Protocol.WriteToLocalIndexThread(Segment segment,
                                java.util.Collection<SolrInputDocument> docs)

Parameters must be not null.

Parameters:

segment - solr segment to write

docs - solr documents collection to put to segment

Method Detail

stopWriting

public void stopWriting()

Use this to stop writing operation. This thread will not stop immediately as Solr might be writing something.

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread