多线程-并发容器（ConcurrentHashMap，CopyOnWriteListArrayList，BlockingQueu.... ）
public class Indexerimplements Runnable { private final BlockingQueue<File> queue; public Indexer(BlockingQueue<File> queue){ this.queue=queue; } public void run() { try { while (true){ indexFile(queue.take()); } }catch (InterruptedException e){ Thread.currentThread().interrupt(); } }}

?以上两段伪代码，是对阻塞队列的使用