知识大全基于线程池的匹配文件数量计算

Posted 2022-07-18 知

篇首语：锲而舍之，朽木不折;锲而不舍，金石可镂。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全基于线程池的匹配文件数量计算相关的知识，希望对你有一定的参考价值。

构建一个新的线程的代价还是有些高的因为它涉及与操作系统的交互如果你的程序创建了大量生存期很短的线程那就应该使用线程池一个线程池包含大量准备运行的空闲线程你将一个Runnable对象给线程池线程池中的一个线程就会调用run方法当run方法退出时线程不会死亡而是继续在池中准备为下一个请求提供服务执行器（Executor）类有大量用来构建线程池的静态工厂方法下表给出了一个总结 newCachedThreadPool newFixedThreadPool和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<?> 可使用该对象调用isDone cancel 或者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 java io *; import java util *; import ncurrent *; public class ThreadPoolTest public static void main（String[] args） throws Exception Scanner in = new Scanner（System in） System out print（ Enter base directory （e g /usr/local/jdk /src）） String directory = in nextLine（） System out print（ Enter keyword （e g volatile）） String keyword = in nextLine（） ExecutorService pool = Executors newCachedThreadPool（） MatchCounter counter = new MatchCounter（new File（directory） keyword pool） Future<Integer> result = pool submit（counter） try System out println（result get（） + matching files ） catch （ExecutionException e） e printStackTrace（） catch （InterruptedException e） pool shutdown（） int largestPoolSize = （（ThreadPoolExecutor） pool） getLargestPoolSize（） System out println（ 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） this directory = directory; this keyword = keyword; this pool = pool; public Integer call（） count = ; try File[] files = directory listFiles（） ArrayList<Future<Integer》 results = new ArrayList<Future<Integer》（） for （File file : files） if （file isDirectory（）） MatchCounter counter = new MatchCounter（file keyword pool） Future<Integer> result = pool submit（counter） results add（result） else if （search（file）） count++; for （Future<Integer> result : results） try count += result get（） catch （ExecutionException e） e printStackTrace（） 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 && in hasNextLine（）） String line = in nextLine（） if （ntains（keyword）） found = true; in close（） return found; catch （IOException e） return false; private File directory; private String keyword; private ExecutorService pool; private int count; cha138/Article/program/Java/gj/201311/27555

知识大全 基于线程池的匹配文件数量计算

知识大全基于线程池的匹配文件数量计算