Вижу данный подход:
1.Поток Отбирает файлы с нужным расширением
Создаем Map где ключ Path а Содержание List-файла И добавляем туда все найденные файлы
2.Поток берет данные с этой карты и Ищит в значениях совпадение по тексту!
Дальше заносит Путь файла в Лист=получаем результат.
Последовательно программа работает! Причем довольна быстро!
Вопрос в том как настроить именно параллельную работу! Вот мои потуги по этому поводу!Результат не убедительный, так как программа вс равно работает последовательно!
1ый поток запускает метод WalkTree
public class ThreadSearch extends Thread {
private String dirr;
private MyFileVisitorParallSearch myfl;
public ThreadSearch(String dirr, MyFileVisitorParallSearch myfl) {
this.dirr = dirr;
this.myfl = myfl;
}
@Override
public void run() {
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Дерево каталогов начиная с каталога: " + dirr + "\n");
try {
Files.walkFileTree(Paths.get(dirr), myfl);
} catch (IOException e) {
System.out.println("Ошибка Ввода Вывода " + e);
}
}
}
Мой интерфейс Визитор
public class MyFileVisitorParallSearch extends SimpleFileVisitor<Path> {
private String extc;
private List<String> resultList = new ArrayList<>();
private HashMap<Path, List<String>> map = new HashMap<>();
public MyFileVisitorParallSearch(String extc) {
this.extc = extc;
}
public HashMap<Path, List<String>> getMap() {
return map;
}
public List<String> getResultlist() {
return resultList;
}
@Override
public FileVisitResult preVisitDirectory(Path path, BasicFileAttributes attribs) throws IOException {
//Ignore Dirr
Path ignorepath1 = Paths.get("C:\\projects\\java-a-to-z\\.git");
Path ignorepath2 = Paths.get("C:\\projects\\java-a-to-z\\.idea");
if (path.equals(ignorepath1) || path.equals(ignorepath2)) {
return FileVisitResult.SKIP_SUBTREE;
} else {
return FileVisitResult.CONTINUE;
}
}
@Override
public FileVisitResult visitFile(Path path, BasicFileAttributes attributes) throws IOException {
String myRegex = "\\w+\\." + extc;
Pattern p = Pattern.compile(myRegex);
Matcher m = p.matcher(String.valueOf(path));
if (m.find()) {
List<String> list = Files.lines(path).collect(Collectors.toList());
map.put(path, list);
return FileVisitResult.CONTINUE;
}
return FileVisitResult.SKIP_SUBTREE;
}
}
Второй поток работает с мапой и передает результат в Лист результатов
public class ThreadFindText extends Thread {
private String text;
private List<String> resultList = new ArrayList<>();
private MyFileVisitorParallSearch myfl;
int count = 0;
public ThreadFindText(String text, MyFileVisitorParallSearch myfl) {
this.text = text;
this.myfl = myfl;
}
public List<String> getResultList() {
return resultList;
}
public void run() {
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
for (Path path : myfl.getMap().keySet()) {
for (String element : myfl.getMap().get(path)) {
Pattern pfind = Pattern.compile("\\b" + text + "\\b");
Matcher mfind = pfind.matcher(element);
if (mfind.find()) {
myfl.getResultlist().add(String.valueOf(path));
break;
}
}
}
}
}
Метод Маин
public class MainTest {
public static void main(String[] args) throws InterruptedException {
String dir = "C:";
String text = "MyFileVisitorParallSearch";
String extc = "java";
MyFileVisitorParallSearch myfl = new MyFileVisitorParallSearch(extc);
ThreadFindText threadFind = new ThreadFindText(text, myfl);
ThreadSearch threadSearch = new ThreadSearch(dir, myfl);
Long startTime = System.currentTimeMillis();
threadSearch.start();
threadSearch.join();
threadFind.start();
threadFind.join();
Long finishTime = System.currentTimeMillis() - startTime;
for (String element : myfl.getResultlist()) {
System.out.println(element);
}
System.out.println(finishTime);
}
}