一段关于lucene的代码，不知道那里有问题

//这段代码很奇怪，线程开10没有问题，但是超过10个就会有很多奇怪的问题，不知道是不是我的硬件不支持还是本身这段代码就有问题

public class IndexCreateThread {
	public static void main(String[] args) throws CorruptIndexException,
			LockObtainFailedException, IOException, InterruptedException {
		IndexWriter writer = new IndexWriter(FSDirectory.getDirectory("E:/Lucene/Index6"), new StandardAnalyzer(), true);
		LinkedList<RAMDirectory> list = new LinkedList<RAMDirectory>();
		Runnable indexListThread = new IndexListThread(list,writer);
		new Thread(indexListThread).start();
		Runnable ramIndexCreateThread = null;
		for (int i = 0; i < 15; i++) {
			ramIndexCreateThread = new RamIndexCreateThread(list);
			new Thread(ramIndexCreateThread).start();
			Thread.sleep(i*3);
		}
		Thread.sleep(5000*10);

		while (true) {
			if (list != null && list.size() == 0) {
				System.out.println(writer.docCount());
				writer.optimize();
				writer.flush();
				writer.close();
				System.out.println("over....");
				System.exit(0);
			} else {
				Thread.sleep(1000);
			}
		}
	}

}

class IndexListThread implements Runnable{
	private LinkedList<RAMDirectory> list = null;
	private IndexWriter writer = null;
	
	public IndexListThread(LinkedList<RAMDirectory> list, IndexWriter writer) {
		super();
		this.list = list;
		this.writer = writer;
	}

	@Override
	public void run() {
		while(true){
			RAMDirectory r = null;
			try {
				Thread.sleep(5);
			} catch (InterruptedException e1) {
				e1.printStackTrace();
			}
			if(list != null && list.size() > 0){
				r = list.get(0);
				try {
					this.writer.addIndexes(new Directory[]{r});
				} catch (CorruptIndexException e) {
					e.printStackTrace();
				} catch (IOException e) {
					e.printStackTrace();
				}
				list.remove(r);
				System.out.println("list 出来一个");
			}
		}
	}
}

class RamIndexCreateThread implements Runnable {
	private LinkedList<RAMDirectory> list = null;
	public RamIndexCreateThread(LinkedList<RAMDirectory> list) {
		this.list = list;
	}

	@Override
	public void run() {
		IndexWriter ramWriter = null;
		try {
			RAMDirectory ram = new RAMDirectory();
			ramWriter = new IndexWriter(ram,new StandardAnalyzer(), true);
			List<Authors> list = new DBOperation().getAuthorses();
			for(Authors s : list){
				Field f1 = new Field("id",s.getAu_id(),Field.Store.YES,Field.Index.UN_TOKENIZED);
				Field f2 = new Field("lname",s.getAu_lname(),Field.Store.YES,Field.Index.TOKENIZED);
				Field f3 = new Field("fname",s.getAu_fname(),Field.Store.YES,Field.Index.UN_TOKENIZED);
				Field f4 = new Field("phone",s.getPhone(),Field.Store.YES,Field.Index.TOKENIZED);
				Field f5 = new Field("address",s.getAddress(),Field.Store.YES,Field.Index.TOKENIZED);
				Field f6 = new Field("city",s.getCity(),Field.Store.YES,Field.Index.TOKENIZED);
				Field f7 = new Field("zip",s.getZip(),Field.Store.YES,Field.Index.TOKENIZED);
				Field f8 = new Field("state",s.getState(),Field.Store.YES,Field.Index.TOKENIZED);
				Field f9 = new Field("contract",s.getContract()+"",Field.Store.YES,Field.Index.TOKENIZED);
				Document doc = new Document();
				doc.add(f1);
				doc.add(f2);
				doc.add(f3);
				doc.add(f4);
				doc.add(f5);
				doc.add(f6);
				doc.add(f7);
				doc.add(f8);
				doc.add(f9);
				ramWriter.addDocument(doc);
			}
			ramWriter.flush();
			this.list.add(ram);
			System.out.println("list的进去一个");
		} catch (CorruptIndexException e) {
			e.printStackTrace();
		} catch (LockObtainFailedException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}finally{
			try {
				ramWriter.close();
			} catch (CorruptIndexException e) {
			} catch (IOException e) {
			}
		}
	}

}

 

评论

3 楼 fys124974704 2008-09-26  

我今天再测试了一下 发现原来我那数据连的数据库数据太多了 一次拿了7千多条，然后修改了为每次拿几十条后，用99条线程同时并发，没有问题了！这个和线程的容器应该没有关系 我还是用LinkedList

2 楼 fys124974704 2008-09-26  

能不能详细一点呢？线程不安全的容器？？

1 楼 javaeyes 2008-09-26  

高手啊，佩服。。。。。。。。。
一个不是线程安全的容器，让多线程访问，不出错才怪