2

Как остановить поток?

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;
        }
    }
}
0

1 ответ 1

5

Поток должен сам управлять своим жизненным циклом, из другого потока его останавливать нельзя. В вашем случае, чтобы исключить зависание, стоит использовать таймаут при получении данных:

path = get(paths.poll(1, TimeUnit.SECONDS));

Использовать таймауты блокирующих вызовов - это всегда хорошая практика.

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.