Как остановить поток?
public class ParallelSearch {
private final String root;
private final String text;
private final Set<String> exts;
private volatile boolean finish = false;
private final BlockingDeque<String> paths = new LinkedBlockingDeque<>();
public ParallelSearch(String root, String text, Set<String> exts) {
this.root = root;
this.text = text;
this.exts = exts;
}
public void init() {
Thread search = new Thread() {
@Override
public void run() {
Set<FileVisitOption> opts = Collections.emptySet();
final int maxDeph = Integer.MAX_VALUE;
try {
Files.walkFileTree(get(root), opts, maxDeph, new MyFileVisitor());
} catch (IOException e) {
e.printStackTrace();
}
finish = true;
}
};
Thread read = new Thread() {
@Override
public void run() {
while (!finish || paths.size() > 0) {
Path path = null;
try {
//вот тут поток остановится и будет ждать появления файла, а что если файл так и не придёт??????то поток так и зависнет?.... как остановить поток?
path = get(paths.take());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
read.start();
search.start();
try {
search.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
try {
read.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
synchronized List<String> result() {
return this.files;
}
private class MyFileVisitor implements FileVisitor<Path> {
//действия при посещении каталога
@Override
public FileVisitResult preVisitDirectory(Path dir, BasicFileAttributes attrs) throws IOException {
return FileVisitResult.CONTINUE;
}
//действия при посещении каждого файла
@Override
public FileVisitResult visitFile(Path file, BasicFileAttributes attrs) throws IOException {
//не важно что тут будет происходить
return FileVisitResult.CONTINUE;
}
@Override
public FileVisitResult visitFileFailed(Path file, IOException exc) throws IOException {
//но если указать несуществующий каталог , то тут можно сгенерировать исключение
System.out.println("исключение отловлено файл не читается");
return FileVisitResult.CONTINUE;
}
@Override
public FileVisitResult postVisitDirectory(Path dir, IOException exc) throws IOException {
return FileVisitResult.CONTINUE;
}
}
}