文章列表
package com.sunrise.mywork2.concurrent.queue;import java.io.File;import java.io.FileFilter;import java.util.concurrent.BlockingQueue;import java.util.concurrent.LinkedBlockingQueue;public class IndexingService{private static final int CAPACITY = 1000;private static final File POISON = new Fil ...