Searched defs:threads (Results 1 - 14 of 14) sorted by relevance

/lucene-3.6.0/lucene/core/src/java/org/apache/lucene/index/
H A DDocConsumer.java25 abstract void flush(final Collection<DocConsumerPerThread> threads, final SegmentWriteState state) throws IOException; argument
H A DDocFieldProcessor.java50 public void flush(Collection<DocConsumerPerThread> threads, SegmentWriteState state) throws IOException { argument
53 for ( DocConsumerPerThread thread : threads) {
/lucene-3.6.0/lucene/core/src/test/org/apache/lucene/index/
H A DTestAtomicUpdate.java55 TimedThread(TimedThread[] threads) { argument
56 this.allThreads = threads;
88 public IndexerThread(IndexWriter writer, TimedThread[] threads) { argument
89 super(threads);
108 public SearcherThread(Directory directory, TimedThread[] threads) { argument
109 super(threads);
127 TimedThread[] threads = new TimedThread[4];
152 IndexerThread indexerThread = new IndexerThread(writer, threads);
153 threads[0] = indexerThread;
156 IndexerThread indexerThread2 = new IndexerThread(writer, threads);
[all...]
H A DTestStressIndexing.java35 TimedThread(TimedThread[] threads) { argument
36 this.allThreads = threads;
70 public IndexerThread(IndexWriter writer, TimedThread[] threads) { argument
71 super(threads);
98 public SearcherThread(Directory directory, TimedThread[] threads) { argument
99 super(threads);
126 TimedThread[] threads = new TimedThread[4];
132 IndexerThread indexerThread = new IndexerThread(modifier, threads);
133 threads[numThread++] = indexerThread;
136 IndexerThread indexerThread2 = new IndexerThread(modifier, threads);
[all...]
H A DTestTransactions.java50 TimedThread(TimedThread[] threads) { argument
51 this.allThreads = threads;
84 public IndexerThread(Object lock, Directory dir1, Directory dir2, TimedThread[] threads) { argument
85 super(threads);
170 public SearcherThread(Object lock, Directory dir1, Directory dir2, TimedThread[] threads) { argument
171 super(threads);
216 TimedThread[] threads = new TimedThread[3];
219 IndexerThread indexerThread = new IndexerThread(this, dir1, dir2, threads);
220 threads[numThread++] = indexerThread;
223 SearcherThread searcherThread1 = new SearcherThread(this, dir1, dir2, threads);
[all...]
H A DTestAddIndexes.java626 final Thread[] threads = new Thread[NUM_THREADS]; field in class:TestAddIndexes.RunAddIndexesThreads
652 threads[i] = new Thread() {
677 threads[i].start();
682 threads[i].join();
752 // from multiple threads
803 // Close w/o first stopping/joining the threads
890 // Close w/o first stopping/joining the threads
899 System.out.println("TEST: done join threads");
915 // Close w/o first stopping/joining the threads
H A DTestIndexWriterReader.java398 final Thread[] threads = new Thread[NUM_THREADS]; field in class:TestIndexWriterReader.AddDirectoriesThreads
426 threads[i].join();
455 threads[i] = new Thread() {
482 threads[i].start();
740 final Thread[] threads = new Thread[NUM_THREAD];
742 threads[i] = new Thread() {
756 threads[i].setDaemon(true);
757 threads[i].start();
776 threads[i].join();
823 final Thread[] threads
[all...]
H A DTestStressIndexing2.java134 IndexingThread[] threads; field in class:TestStressIndexing2
142 // indexing threads to test that IndexWriter does correctly synchronize
166 threads = new IndexingThread[nThreads];
167 for (int i=0; i<threads.length; i++) {
173 threads[i] = th;
176 for (int i=0; i<threads.length; i++) {
177 threads[i].start();
179 for (int i=0; i<threads.length; i++) {
180 threads[i].join();
186 for (int i=0; i<threads
[all...]
/lucene-3.6.0/lucene/backwards/src/test/org/apache/lucene/index/
H A DTestAtomicUpdate.java55 TimedThread(TimedThread[] threads) { argument
56 this.allThreads = threads;
88 public IndexerThread(IndexWriter writer, TimedThread[] threads) { argument
89 super(threads);
108 public SearcherThread(Directory directory, TimedThread[] threads) { argument
109 super(threads);
127 TimedThread[] threads = new TimedThread[4];
152 IndexerThread indexerThread = new IndexerThread(writer, threads);
153 threads[0] = indexerThread;
156 IndexerThread indexerThread2 = new IndexerThread(writer, threads);
[all...]
H A DTestStressIndexing.java35 TimedThread(TimedThread[] threads) { argument
36 this.allThreads = threads;
70 public IndexerThread(IndexWriter writer, TimedThread[] threads) { argument
71 super(threads);
98 public SearcherThread(Directory directory, TimedThread[] threads) { argument
99 super(threads);
126 TimedThread[] threads = new TimedThread[4];
132 IndexerThread indexerThread = new IndexerThread(modifier, threads);
133 threads[numThread++] = indexerThread;
136 IndexerThread indexerThread2 = new IndexerThread(modifier, threads);
[all...]
H A DTestTransactions.java50 TimedThread(TimedThread[] threads) { argument
51 this.allThreads = threads;
84 public IndexerThread(Object lock, Directory dir1, Directory dir2, TimedThread[] threads) { argument
85 super(threads);
170 public SearcherThread(Object lock, Directory dir1, Directory dir2, TimedThread[] threads) { argument
171 super(threads);
216 TimedThread[] threads = new TimedThread[3];
219 IndexerThread indexerThread = new IndexerThread(this, dir1, dir2, threads);
220 threads[numThread++] = indexerThread;
223 SearcherThread searcherThread1 = new SearcherThread(this, dir1, dir2, threads);
[all...]
H A DTestAddIndexes.java626 final Thread[] threads = new Thread[NUM_THREADS]; field in class:TestAddIndexes.RunAddIndexesThreads
652 threads[i] = new Thread() {
677 threads[i].start();
682 threads[i].join();
752 // from multiple threads
803 // Close w/o first stopping/joining the threads
890 // Close w/o first stopping/joining the threads
899 System.out.println("TEST: done join threads");
915 // Close w/o first stopping/joining the threads
H A DTestIndexWriterReader.java396 final Thread[] threads = new Thread[NUM_THREADS]; field in class:TestIndexWriterReader.AddDirectoriesThreads
424 threads[i].join();
453 threads[i] = new Thread() {
480 threads[i].start();
738 final Thread[] threads = new Thread[NUM_THREAD];
740 threads[i] = new Thread() {
754 threads[i].setDaemon(true);
755 threads[i].start();
774 threads[i].join();
820 final Thread[] threads
[all...]
H A DTestStressIndexing2.java133 IndexingThread[] threads; field in class:TestStressIndexing2
141 // indexing threads to test that IndexWriter does correctly synchronize
165 threads = new IndexingThread[nThreads];
166 for (int i=0; i<threads.length; i++) {
172 threads[i] = th;
175 for (int i=0; i<threads.length; i++) {
176 threads[i].start();
178 for (int i=0; i<threads.length; i++) {
179 threads[i].join();
185 for (int i=0; i<threads
[all...]

Completed in 3309 milliseconds