参考 : http://blog.csdn.net/madun/article/details/20313269
创建线程池
ExecutorService service= Executors.newFixedThreadPool(nThreads);
提交线程:
//TODO 有返回状态处理 service.submit(new LoadDataThread(startDocId, endDocId, luceneFileDir,this.queue,this.docs));
线程安全队列:
LinkedBlockingQueue<Document> queue=new LinkedBlockingQueue<Document>(this.numDocs);
BlockingQueue,顾名思义,“阻塞队列”:可以提供阻塞功能的队列。
首先,看看BlockingQueue提供的常用方法:
从上表可以很明显看出每个方法的作用,这个不用多说。我想说的是:
|
线程创建:
/** * 加载数据线程 */ public class LoadDataThread implements Runnable
时间: 2024-10-06 00:43:13