国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 學院 > 開發設計 > 正文

利用Fork/Join框架來統計某個字符串在某個文件夾的文件中出現的次數

2019-11-11 05:14:59
字體:
來源:轉載
供稿:網友
需求:利用Fork/Join框架來統計某個字符串在某個文件夾的文件中出現的次數。主要用到的技術點:JDK8的Stream、Lambda表達式、Fork/Join框架.

如果對于Fork/Join不了解的話可以參考這里:http://www.infoq.com/cn/articles/fork-join-introduction、http://ifeve.com/fork-join-1/、http://www.iteye.com/topic/643724 。主要代碼如下:

package com.zkn.fullstacktraining.seventh;import com.google.common.collect.Lists;import javafx.util.Pair;import java.io.IOException;import java.nio.file.Files;import java.nio.file.Path;import java.nio.file.Paths;import java.util.List;import java.util.Optional;import java.util.concurrent.ExecutionException;import java.util.concurrent.ForkJoinPool;import java.util.concurrent.Future;import java.util.concurrent.RecursiveTask;import java.util.stream.Collectors;import java.util.stream.IntStream;/** * Created by wb-zhangkenan on 2017/2/6. * 通過Fork/Join的方式來統計某個字符串在某個文件夾下的文件中出現的次數 */public class SearchStringByForkJoin extends RecursiveTask<List<Pair<String, Integer>>> { //任務的閥值 PRivate static final int THRESHOLD = 5; //任務區間的開始值 private int start; //任務區間的結束值 private int end; //所有的路徑信息 private List<Path> allPaths; public SearchStringByForkJoin(int start, int end, List<Path> allPaths) { this.start = start; this.end = end; this.allPaths = allPaths; } public static void main(String[] args) { ForkJoinPool forkJoinPool = new ForkJoinPool(); try { List<Path> pathList = Files.walk(Paths.get("D://CUST//WORK//Exercises//FullStackTraining//src//main//java//com//zkn"), 4) .filter(file -> !Files.isDirectory(file) && file.toString().endsWith("java")) .collect(Collectors.toList()); SearchStringByForkJoin searchStringByForkJoin = new SearchStringByForkJoin(0, pathList.size(), pathList); Future<List<Pair<String, Integer>>> result = forkJoinPool.submit(searchStringByForkJoin); List<Pair<String, Integer>> pairList = result.get(); pairList.stream() .filter(pair -> pair.getValue() > 0) .sorted((s1, s2) -> Integer.compare(s2.getValue(), s1.getValue())) .forEach(pair -> System.out.println(String.format("%d次出現在%s文件中", pair.getValue(), pair.getKey().toString()))); forkJoinPool.shutdown(); } catch (IOException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } } /** * The main computation performed by this task. * @return the result of the computation */ @Override protected List<Pair<String, Integer>> compute() { List<Pair<String, Integer>> pairList = Lists.newArrayList(); boolean canCompute = end - start <= THRESHOLD; if (canCompute) { pairList = IntStream.range(start, end + 1).mapToObj(i -> { //到集合的結尾了 if (i == allPaths.size()) return new Pair<>("", 0); int sum = 0; try { Optional optional = Files.lines(allPaths.get(i)).map(file -> { int count = 0; int flag = file.indexOf("main"); if (flag >= 0) { do { count++; } while ((flag = file.indexOf("main", flag + 1)) > 0); } return count; }).reduce(Integer::sum); sum = optional.isPresent() ? (int) optional.get() : 0; } catch (IOException e) { e.printStackTrace(); } return new Pair<>(allPaths.get(i).toString(), sum); }).collect(Collectors.toList()); } else { //取中間值 int middle = (end + start) / 2; //創建Fork子任務 SearchStringByForkJoin leftFork = new SearchStringByForkJoin(start, middle, allPaths); //創建Fork子任務 SearchStringByForkJoin rightFork = new SearchStringByForkJoin(middle + 1, end, allPaths); //執行子任務 leftFork.fork(); rightFork.fork(); //合并子任務的結果集 pairList.addAll(leftFork.join()); pairList.addAll(rightFork.join()); } return pairList; }}
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 若尔盖县| 庆云县| 壶关县| 土默特左旗| 石门县| 静海县| 西吉县| 恩施市| 海淀区| 淄博市| 鹿泉市| 丹阳市| 即墨市| 夏河县| 静宁县| 婺源县| 大悟县| 武平县| 乌兰察布市| 纳雍县| 郯城县| 白城市| 宝山区| 玛多县| 瑞昌市| 河东区| 永丰县| 监利县| 察雅县| 乌海市| 漳州市| 武宣县| 班玛县| 如皋市| 临泽县| 蒙城县| 嫩江县| 伊金霍洛旗| 达尔| 浦东新区| 崇信县|