lucene-java-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From o...@apache.org
Subject svn commit: r487922 - /lucene/java/trunk/src/test/org/apache/lucene/search/TestMultiThreadTermVectors.java
Date Sun, 17 Dec 2006 00:10:40 GMT
Author: otis
Date: Sat Dec 16 16:10:40 2006
New Revision: 487922

URL: http://svn.apache.org/viewvc?view=rev&rev=487922
Log:
- Typo and tabs

Modified:
    lucene/java/trunk/src/test/org/apache/lucene/search/TestMultiThreadTermVectors.java

Modified: lucene/java/trunk/src/test/org/apache/lucene/search/TestMultiThreadTermVectors.java
URL: http://svn.apache.org/viewvc/lucene/java/trunk/src/test/org/apache/lucene/search/TestMultiThreadTermVectors.java?view=diff&rev=487922&r1=487921&r2=487922
==============================================================================
--- lucene/java/trunk/src/test/org/apache/lucene/search/TestMultiThreadTermVectors.java (original)
+++ lucene/java/trunk/src/test/org/apache/lucene/search/TestMultiThreadTermVectors.java Sat
Dec 16 16:10:40 2006
@@ -36,160 +36,160 @@
   private RAMDirectory directory = new RAMDirectory();
   public int numDocs = 100;
   public int numThreads = 3;
-	
+  
   public TestMultiThreadTermVectors(String s) {
     super(s);
   }
   
   public void setUp() throws Exception {
-  	IndexWriter writer
+    IndexWriter writer
             = new IndexWriter(directory, new SimpleAnalyzer(), true);
-  	//writer.setUseCompoundFile(false);
-  	//writer.infoStream = System.out;
-  	for (int i = 0; i < numDocs; i++) {
-    	Document doc = new Document();
-    	Fieldable fld = new Field("field", English.intToEnglish(i), Field.Store.YES, Field.Index.UN_TOKENIZED,
Field.TermVector.YES);
-    	doc.add(fld);
-    	writer.addDocument(doc);
-  	}
-  	writer.close();
-  	
-	}
-	
-	public void test() {
-  	
-	  IndexReader reader = null;
-	  
-	  try {
-	    reader = IndexReader.open(directory);
-	    for(int i = 1; i <= numThreads; i++)
-	      testTermPositionVectors(reader, i);
-	  	
-	  	
-  	}
-		catch (IOException ioe) {
-			fail(ioe.getMessage());
-		}
-		finally {
-		  if (reader != null) {
-		    try {
-		      /** close the opened reader */
-		      reader.close();
-		    } catch (IOException ioe) {
-		      ioe.printStackTrace();
-		    }
-		  }
-		}
-	}
-	
-	public void testTermPositionVectors(final IndexReader reader, int threadCount) {
-		MultiThreadTermVectorsReader[] mtr = new MultiThreadTermVectorsReader[threadCount];
-		for (int i = 0; i < threadCount; i++) {
-			mtr[i] = new MultiThreadTermVectorsReader();
-			mtr[i].init(reader);
-		}
-		
-		
-		/** run until all threads finished */ 
-		int threadsAlive = mtr.length;
-		while (threadsAlive > 0) {
-			try {
-				//System.out.println("Threads alive");
-				Thread.sleep(10);
-				threadsAlive = mtr.length;
-				for (int i = 0; i < mtr.length; i++) {
-					if (mtr[i].isAlive() == true) {
-						break;
-					}
-					
-					threadsAlive--; 
-					
-			}
-				
-			} catch (InterruptedException ie) {} 
-		}
-		
-		long totalTime = 0L;
-		for (int i = 0; i < mtr.length; i++) {
-			totalTime += mtr[i].timeElapsed;
-			mtr[i] = null;
-		}
-		
-		//System.out.println("threadcount: " + mtr.length + " average term vector time: " + totalTime/mtr.length);
-		
-	}
-	
+    //writer.setUseCompoundFile(false);
+    //writer.infoStream = System.out;
+    for (int i = 0; i < numDocs; i++) {
+      Document doc = new Document();
+      Fieldable fld = new Field("field", English.intToEnglish(i), Field.Store.YES, Field.Index.UN_TOKENIZED,
Field.TermVector.YES);
+      doc.add(fld);
+      writer.addDocument(doc);
+    }
+    writer.close();
+    
+  }
+  
+  public void test() {
+    
+    IndexReader reader = null;
+    
+    try {
+      reader = IndexReader.open(directory);
+      for(int i = 1; i <= numThreads; i++)
+        testTermPositionVectors(reader, i);
+      
+      
+    }
+    catch (IOException ioe) {
+      fail(ioe.getMessage());
+    }
+    finally {
+      if (reader != null) {
+        try {
+          /** close the opened reader */
+          reader.close();
+        } catch (IOException ioe) {
+          ioe.printStackTrace();
+        }
+      }
+    }
+  }
+  
+  public void testTermPositionVectors(final IndexReader reader, int threadCount) {
+    MultiThreadTermVectorsReader[] mtr = new MultiThreadTermVectorsReader[threadCount];
+    for (int i = 0; i < threadCount; i++) {
+      mtr[i] = new MultiThreadTermVectorsReader();
+      mtr[i].init(reader);
+    }
+    
+    
+    /** run until all threads finished */ 
+    int threadsAlive = mtr.length;
+    while (threadsAlive > 0) {
+      try {
+        //System.out.println("Threads alive");
+        Thread.sleep(10);
+        threadsAlive = mtr.length;
+        for (int i = 0; i < mtr.length; i++) {
+          if (mtr[i].isAlive() == true) {
+            break;
+          }
+          
+          threadsAlive--; 
+          
+      }
+        
+      } catch (InterruptedException ie) {} 
+    }
+    
+    long totalTime = 0L;
+    for (int i = 0; i < mtr.length; i++) {
+      totalTime += mtr[i].timeElapsed;
+      mtr[i] = null;
+    }
+    
+    //System.out.println("threadcount: " + mtr.length + " average term vector time: " + totalTime/mtr.length);
+    
+  }
+  
 }
 
 class MultiThreadTermVectorsReader implements Runnable {
-	
-	private IndexReader reader = null;
-	private Thread t = null;
-	
-	private final int runsToDo = 100;
-	long timeElapsed = 0;
-	
-	
-	public void init(IndexReader reader) {
-		this.reader = reader;
-		timeElapsed = 0;
-		t=new Thread(this);
-		t.start();
-	}
-		
-	public boolean isAlive() {
-		if (t == null) return false;
-		
-		return t.isAlive();
-	}
-	
-	public void run() {
-			try {
-				// run the test 100 times
-				for (int i = 0; i < runsToDo; i++)
-					testTermVectors();
-			}
-			catch (Exception e) {
-				e.printStackTrace();
-			}
-			return;
-	}
-	
-	private void testTermVectors() throws Exception {
-		// check:
-		int numDocs = reader.numDocs();
-		long start = 0L;
-		for (int docId = 0; docId < numDocs; docId++) {
-			start = System.currentTimeMillis();
-			TermFreqVector [] vectors = reader.getTermFreqVectors(docId);
-			timeElapsed += System.currentTimeMillis()-start;
-			
-			// verify vectors result
-			verifyVectors(vectors, docId);
-			
-			start = System.currentTimeMillis();
-			TermFreqVector vector = reader.getTermFreqVector(docId, "field");
-			timeElapsed += System.currentTimeMillis()-start;
-			
-			vectors = new TermFreqVector[1];
-			vectors[0] = vector;
-			
-			verifyVectors(vectors, docId);
-			
-		}
-	}
-	
-	private void verifyVectors(TermFreqVector[] vectors, int num) {
-		StringBuffer temp = new StringBuffer();
-		String[] terms = null;
-		for (int i = 0; i < vectors.length; i++) {
-			terms = vectors[i].getTerms();
-			for (int z = 0; z < terms.length; z++) {
-				temp.append(terms[z]);
-			}
-		}
-		
-		if (!English.intToEnglish(num).trim().equals(temp.toString().trim()))
-				System.out.println("worng term result");
-	}
+  
+  private IndexReader reader = null;
+  private Thread t = null;
+  
+  private final int runsToDo = 100;
+  long timeElapsed = 0;
+  
+  
+  public void init(IndexReader reader) {
+    this.reader = reader;
+    timeElapsed = 0;
+    t=new Thread(this);
+    t.start();
+  }
+    
+  public boolean isAlive() {
+    if (t == null) return false;
+    
+    return t.isAlive();
+  }
+  
+  public void run() {
+      try {
+        // run the test 100 times
+        for (int i = 0; i < runsToDo; i++)
+          testTermVectors();
+      }
+      catch (Exception e) {
+        e.printStackTrace();
+      }
+      return;
+  }
+  
+  private void testTermVectors() throws Exception {
+    // check:
+    int numDocs = reader.numDocs();
+    long start = 0L;
+    for (int docId = 0; docId < numDocs; docId++) {
+      start = System.currentTimeMillis();
+      TermFreqVector [] vectors = reader.getTermFreqVectors(docId);
+      timeElapsed += System.currentTimeMillis()-start;
+      
+      // verify vectors result
+      verifyVectors(vectors, docId);
+      
+      start = System.currentTimeMillis();
+      TermFreqVector vector = reader.getTermFreqVector(docId, "field");
+      timeElapsed += System.currentTimeMillis()-start;
+      
+      vectors = new TermFreqVector[1];
+      vectors[0] = vector;
+      
+      verifyVectors(vectors, docId);
+      
+    }
+  }
+  
+  private void verifyVectors(TermFreqVector[] vectors, int num) {
+    StringBuffer temp = new StringBuffer();
+    String[] terms = null;
+    for (int i = 0; i < vectors.length; i++) {
+      terms = vectors[i].getTerms();
+      for (int z = 0; z < terms.length; z++) {
+        temp.append(terms[z]);
+      }
+    }
+    
+    if (!English.intToEnglish(num).trim().equals(temp.toString().trim()))
+        System.out.println("wrong term result");
+  }
 }



Mime
View raw message