7 #ifndef CONCURRENTMERGESCHEDULER_H
8 #define CONCURRENTMERGESCHEDULER_H
27 int32_t mergeThreadPriority;
45 virtual void initialize();
50 virtual void setMaxThreadCount(int32_t count);
53 virtual int32_t getMaxThreadCount();
57 virtual int32_t getMergeThreadPriority();
60 virtual void setMergeThreadPriority(int32_t pri);
69 static bool anyUnhandledExceptions();
70 static void clearUnhandledExceptions();
73 void setSuppressExceptions();
74 void clearSuppressExceptions();
77 static void setTestMode();
80 virtual bool verbose();
81 virtual void message(
const String& message);
82 virtual void initMergeThreadPriority();
83 virtual int32_t mergeThreadCount();
93 virtual void addMyself();
95 friend class MergeThread;
boost::shared_ptr< OneMerge > OneMergePtr
Definition: LuceneTypes.h:192
boost::shared_ptr< MergeThread > MergeThreadPtr
Definition: LuceneTypes.h:177
boost::shared_ptr< IndexWriter > IndexWriterPtr
Definition: LuceneTypes.h:160
IndexWriterWeakPtr _writer
Definition: ConcurrentMergeScheduler.h:37
bool closed
Definition: ConcurrentMergeScheduler.h:36
boost::weak_ptr< IndexWriter > IndexWriterWeakPtr
Definition: LuceneTypes.h:160
SetMergeThread mergeThreads
Definition: ConcurrentMergeScheduler.h:29
int32_t maxThreadCount
Max number of threads allowed to be merging at once.
Definition: ConcurrentMergeScheduler.h:32
bool suppressExceptions
Definition: ConcurrentMergeScheduler.h:41
boost::shared_ptr< Directory > DirectoryPtr
Definition: LuceneTypes.h:489
#define LUCENE_CLASS(Name)
Definition: LuceneObject.h:24
Definition: AbstractAllTermDocs.h:12
Lucene exception container.
Definition: LuceneException.h:15
A MergeScheduler that runs each merge using a separate thread, up until a maximum number of threads (...
Definition: ConcurrentMergeScheduler.h:19
static Collection< ConcurrentMergeSchedulerPtr > allInstances
Definition: ConcurrentMergeScheduler.h:39
DirectoryPtr dir
Definition: ConcurrentMergeScheduler.h:34
static bool anyExceptions
Definition: ConcurrentMergeScheduler.h:42
IndexWriter uses an instance implementing this interface to execute the merges selected by a MergePol...
Definition: MergeScheduler.h:16