|
构建一个新的线程的代价还是有些高的因为它涉及与操作系统的交互如果你的程序创建了大量生存期很短的线程那就应该使用线程池一个线程池包含大量准备运行的空闲线程你将一个Runnable对象给线程池线程池中的一个线程就会调用run方法当run方法退出时线程不会死亡而是继续在池中准备为下一个请求提供服务 执行器（Executor）类有大量用来构建线程池的静态工厂方法下表给出了一个总结 newCachedThreadPoolnewFixedThreadPool和newSingleThreadExecutor这三个方法返回ThreadPoolExecutor类（这个类实现了ExecutorService接口）对象 向线程池提交任务的方法为将一个实现Runnable或Callable接口的对象提交给ExecutorService: Future<?> submit（Runable task） Future<T> submit（Runable task T result） Future<t> submit（Callable<T> task） 线程池会在适当的时候尽早执行提交的任务调用submit时会返回一个Future对象用以查询该任务的状态或者取消该任务 第一个submit方法提交一个Runable对象返回一个Future<?>可使用该对象调用isDonecancel或者isCancelled来查询任务状态但是此Future对象的get方法在任务完成的时候知识简单的返回null; 第二个版本的submit方法同样提交一个Runable对象并且返回Future的get方法在任务完成的时候返回传入的result对象 第三个submit方法提交一个Callable对象并且返回的Future对象将在计算结构准备好的时候得到它 当想要注销一个线程池可调用shutdown方法该方法启动该线程池的关闭序列此时线程池并不是马上就壮烈牺牲了线程也没了而是等待所以任务都完成以后线程池中的线程才会死亡被关闭的执行器不再接受新任务也可以调用shutdownNow此时线程池会取消正在排队等待处理的任务并且试图中断正在执行的线程 下面总结了在使用连接池时应该做的事 调用Executor类中静态的newCachedThreadPool或newFixedThreadPool方法 调用submit来提交一个Runnable或Callable对象 如果希望能够取消任务或如果提交了一个Callable对象那就保存好返回的Future对象 当不想再提交任何任务时调用shutdown 除了常规的计算匹配文件数量外这个程序打印出执行过程中池中的最大线程数量但从ExecutorService接口不能得到这个信息因此我们必须将pool对象转型成一个ThreadPoolExecutor类对象 import javaio*; import javautil*; import ncurrent*; public class ThreadPoolTest { public static void main（String[] args） throws Exception { Scanner in = new Scanner（Systemin） Systemoutprint（Enter base directory （eg /usr/local/jdk/src） ） String directory = innextLine（） Systemoutprint（Enter keyword （eg volatile） ） String keyword = innextLine（） ExecutorService pool = ExecutorsnewCachedThreadPool（） MatchCounter counter = new MatchCounter（new File（directory） keyword pool） Future<Integer> result = poolsubmit（counter） try { Systemoutprintln（resultget（） + matching files） } catch （ExecutionException e） { eprintStackTrace（） } catch （InterruptedException e） { } poolshutdown（） int largestPoolSize = （（ThreadPoolExecutor） pool）getLargestPoolSize（） Systemoutprintln（largest pool size= + largestPoolSize） } } /** * This task counts the files in a directory and its subdirectories that contain a given keyword */ class MatchCounter implements Callable<Integer> { /** * Constructs a MatchCounter * @param directory the directory in which to start the search * @param keyword the keyword to look for * @param pool the thread pool for submitting subtasks */ public MatchCounter（File directory String keyword ExecutorService pool） { thisdirectory = directory; thiskeyword = keyword; thispool = pool; } public Integer call（） { count = ; try { File[] files = directorylistFiles（） ArrayList<Future<Integer》 results = new ArrayList<Future<Integer》（） for （File file : files） if （fileisDirectory（）） { MatchCounter counter = new MatchCounter（file keyword pool） Future<Integer> result = poolsubmit（counter） resultsadd（result） } else { if （search（file）） count++; } for （Future<Integer> result : results） try { count += resultget（） } catch （ExecutionException e） { eprintStackTrace（） } } catch （InterruptedException e） { } return count; } /** * Searches a file for a given keyword * @param file the file to search * @return true if the keyword is contained in the file */ public boolean search（File file） { try { Scanner in = new Scanner（new FileInputStream（file）） boolean found = false; while （！found && inhasNextLine（）） { String line = innextLine（） if （ntains（keyword）） found = true; } inclose（） return found; } catch （IOException e） { return false; } } private File directory; private String keyword; private ExecutorService pool; private int count; } |
