1

У меня код, в котором работают два параллельных потока, и если они выполняются больше секунды, то надо отменить выполнение обоих потоков. Я хочу использовать для этого конструкцию thread01.isInterrunt(); thread02.isInterrunt(); , но проблема заключается в то что я не понимаю когда именно их вызывать (то есть где).

Вот код:

public class CounterOfSpace {
    private int counterOfSpaces;
    private int counterOfWords;
    private String text;
    private Thread thread01;
    private Thread thread02;

    public CounterOfSpace(String text) {
        this.text = text;
    }

    void startAll() {
        System.out.println("Start program");

        calcWords();
        calcSpaces();
        thread01.start();
        thread02.start();
        try {
            thread01.join();
            thread02.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("Finish program");
    }

    private void calcSpaces() {
        thread01 = new Thread(new Runnable() {
            @Override
            public void run() {
                if (text.length() == 0) return;
                for (char c : text.toCharArray()) {
                    if (c == ' ') {
                        counterOfSpaces++;
                        System.out.println("counterOfSpaces "+counterOfSpaces);
                    }
                }
            }
        });
    }

    private void calcWords() {
        thread02 = new Thread(new Runnable() {
            @Override
            public void run() {
                if (text.length() == 0) return;
                String[] words = text.split(" ");
                for (String word : words) {
                    if (!word.equals(" ")) {
                        counterOfWords++;
                        System.out.println("counterOfWords "+counterOfWords);
                    }
                }
            }
        });
    }
}

Вот где то в методе startAll(), я должен вызвать isInterrunt(), с условием если от момента их запука, прошло времени больше 1 сек. Но где точно, ведь потока 2, и надо прирвать оба, как только время выйдет за границы, а не просто отказаться от использования результата выполнения, если время, больше одной секунды. Подскажите пожалуйста, как мне именно остановить выполнение, как только время превысит 1 сек?

7
  • 1
    Как вариант, сделать ещё поток, который следит за временем 20 мар 2017 в 20:59
  • 1
    опишите задачу, а не решение. 20 мар 2017 в 21:46
  • @Mikhail Vaysman >>>опишите задачу, а не решение<<< в смысле? а что разве я не описал? поясните пожалуйста
    – Pavel
    20 мар 2017 в 23:28
  • вы описали решение - два потока выполняются и т.д. это решение, а не задача. 20 мар 2017 в 23:31
  • @Mikhail Vaysman нет это контекст задачи, а сама задача в то что-бы их остановить при условии... А остановки у меня нигде нет. Где у меня в коде остановка потоков?
    – Pavel
    20 мар 2017 в 23:33

1 ответ 1

2

Используйте ScheduledExecutorService.

ScheduledExecutorService executor = Executors.newScheduledThreadPool(3); 
Future handler1 = executor.submit(thread01);
Future handler2 = executor.submit(thread02);
executor.schedule(() -> {
    handler1.cancel(true);
    handler2.cancel(true);
}, 1000, TimeUnit.MILLISECONDS);

Без лямбды

executor.schedule(new Runnable() {
    @Override
    public void run() {
        handler1.cancel(true);
        handler2.cancel(true);
    }
}, 1000, TimeUnit.MILLISECONDS);
8
  • Спасибо большое. А как бы это выглядело без лямбда выражения?
    – Pavel
    20 мар 2017 в 23:26
  • добавил без лямбды 20 мар 2017 в 23:30
  • Ой извините а мне же задали с isInterrunt() это сделать... Это же не тоже самое?
    – Pavel
    20 мар 2017 в 23:31
  • метод isInterrupted() проверяет прерван ли поток. если вы хотите прервать поток, то это метод interrupt(). мой вариант по сути тоже самое. но можно переделать и под interrupt(). 20 мар 2017 в 23:35
  • Извините что мучаю но не могли бы вы такой вариант тоже добавить а то боюсь задание вернут на переделку а дублировать вопрос нельзя. Или хотя-бы намекните как они друг друга заменяют...
    – Pavel
    20 мар 2017 в 23:37

Ваш ответ

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

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