利用JDK8的新特性計(jì)算某個(gè)目錄下的文件中包含字符串的次數(shù)

2019-11-11 06:43:38

字體：大中小

供稿：網(wǎng)友

需求：計(jì)算某個(gè)字符串在某個(gè)文件夾中出現(xiàn)的次數(shù)。**這篇文章利用了JDK1.8的新特性Stream流和Lambda表達(dá)式并結(jié)合了線程池的使用。**package com.zkn.fullstacktraining.seventh;import javafx.util.Pair;import java.io.IOException;import java.nio.file.Files;import java.nio.file.Paths;import java.util.List;import java.util.Optional;import java.util.concurrent.*;import java.util.stream.Collectors;/** * Created by zkn on 2017/2/5. */public class SearchStringByThreadPool { public static void main(String[] args) { try { //創(chuàng)建5個(gè)固定線程的線程池 ExecutorService executorService = Executors.newFixedThreadPool(5); List<Future<Pair<String, Integer>>> listFile = //這里是取所傳入目錄的最多四層，如果不知道這個(gè)API的話需要遞歸去做。 Files.walk(Paths.get("D://CUST//workspace//JavaCore//FullStackTraining//src//main//java//com//zkn"), 4) .filter(file -> !Files.isDirectory(file) && file.toString().endsWith("java"))//文件文件夾和不是java的文件 .map(file -> (Callable<Pair<String, Integer>>) () -> {//創(chuàng)建N多個(gè)Callable實(shí)現(xiàn)類 Pair<String, Integer> pair = null;//這里的鍵值對(duì)用pair比用Map更好一些 try { Optional optional = Files.lines(file).map(str -> { int count = 0; int index = str.indexOf("main"); if (index >= 0) { //這里需要循環(huán)計(jì)算，因?yàn)榭赡茉谀骋恍兄袝?huì)出現(xiàn)多次 do { count++; } while ((index = str.indexOf("main", index + 1)) > 0); } return count; }).reduce(Integer::sum);//合并最終的計(jì)算結(jié)果 int count = optional.isPResent() ? (int) optional.get() :0; pair = new Pair<>(file.toString(),count); } catch (IOException e) { e.printStackTrace(); } return pair == null ? new Pair<>("", 0) : pair; }) .map(file -> executorService.submit(file))//提交給線程池進(jìn)行處理 .collect(Collectors.toList()); listFile.stream().map(file -> { Pair<String, Integer> pair = null; try { pair = file.get(); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } return pair == null ? new Pair<>("", 0) : pair; }) .filter(file -> file.getValue() > 0)//過(guò)濾掉不包含字符串的文件 .sorted((s1, s2) -> Integer.compare(s2.getValue(), s1.getValue()))//從大到小排序 .forEach(file -> System.out.println(String.format("%d次出現(xiàn)在%s文件中", file.getValue(), file.getKey()))); //關(guān)閉線程池 executorService.shutdown(); } catch (Exception e) { e.printStackTrace(); } } public void test() { String str = "mainmainmainmainmain"; }}

上一篇：未能正確創(chuàng)建Visual c# 20xx,因此未能打開(kāi)工程xxx,請(qǐng)重新安裝Visual studio

下一篇：51nod1050 循環(huán)數(shù)組最大子段和 dp