Lucene3.0.0之样例解析(3)IndexFiles.java

try {

// This call is not synchronized and does all the

// work

final DocWriter perDoc &＃61; state.consumer.processDocument();

// This call is synchronized but fast

finishDocument(state, perDoc);

success &＃61; true;

}

synchronized DocumentsWriterThreadState getThreadState(Document doc, Term delTerm)

state &＃61; newArray[threadStates.length] &＃61; new DocumentsWriterThreadState(this);

consumer &＃61; docWriter.consumer.addThread(this);

DocumentsWriter(Directory directory, IndexWriter writer, IndexingChain indexingChain) throws IOException {

//...省略了

consumer &＃61; indexingChain.getChain(this);

if (consumer instanceof DocFieldProcessor) {

docFieldProcessor &＃61; (DocFieldProcessor) consumer;

}

}

DocConsumer getChain(DocumentsWriter documentsWriter) {

// Build up indexing chain:

final TermsHashConsumer termVectorsWriter &＃61; new TermVectorsTermsWriter(documentsWriter);

final TermsHashConsumer freqProxWriter &＃61; new FreqProxTermsWriter();

final InvertedDocConsumer termsHash &＃61; new TermsHash(documentsWriter, true, freqProxWriter,

new TermsHash(documentsWriter, false, termVectorsWriter, null));

final NormsWriter normsWriter &＃61; new NormsWriter();

final DocInverter docInverter &＃61; new DocInverter(termsHash, normsWriter);

return new DocFieldProcessor(documentsWriter, docInverter);

}

final DocWriter perDoc &＃61; state.consumer.processDocument();