0

Пишу простую программу, она должно создавать необходимое пользователю число потоков и запускать и усыплять на определенное время, после чего выводить их в порядке того, как они просыпались: "Поток" + n + " отдыхал \"" + time + "\" мс";

public class Test {


    private static final int count = 5;

    public static CountDownLatch START = new CountDownLatch(count);

    public static void main(String[] args) {

        ArrayList<NewThread> list = new ArrayList<NewThread>();

        long max = 0;
        long t = 0;

        for(int i = 0; i < count; i++){
            t = (long) (Math.random()*1000);
            list.add(new NewThread(String.valueOf(i), t));
            max = (max <= t) ? (max = t) : (max = max);
        }

        String s = null;

        do {
            try {
                Thread.sleep(max);
                System.out.println("Хотите протестировать еще раз?");
                System.out.println("Для продолжения введите \"Да\"");
                System.out.println("Для окончания введите любое другое сообщения");
                Scanner sc = new Scanner(System.in);
                s = sc.nextLine();
                START = new CountDownLatch(count);
                for (int i = 0; i < count; i++) {
                    t = (long) (Math.random() * 1000);
                    list.get(i).rerun(t);
                    max = (max <= t) ? (max = t) : (max = max);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        while (s.equals("Да"));


    }

    public static class NewThread extends Thread{

        long time;
        String name;

        public NewThread(String name, long time){
            super(name);
            this.name = name;
            this.time = time;
            start();
        }

        @Override
        public void run(){

            try {
                System.out.println("Поток " + name + " готов стартовать");
                START.countDown();

                START.await();

                Thread.sleep(time);
                System.out.println("Поток " + name + " закончил отдых. Он отдыхал \"" + time +"\"");

            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        public void rerun(long time){

            try{
                System.out.println("Поток " + name + " готов отдыхать");
                START.countDown();

                START.await();

                Thread.sleep(time);
                System.out.println("Поток " + name + " закончил отдых. Он отдыхал \"" + time +"\"");
            }
            catch (InterruptedException e){
                e.printStackTrace();
            }

        }


    }


}

Помимо этого после выполнения программа должна спрашивать пользователя хочет ли он повторить прогон и делать тоже самое, только не создавая новых потоков, а используя уже существующие. С этим и возникает загвоздка, создание новых потоков у меня работает корректно, а вот использование уже существующих т.к. я использую метод CountDownLatch await() естественно зависает. Не приходит никакого решения в голову? Можете помочь?

7
  • Попробуйте поменять тактику: если нужно усыпить поток, заканчивайте его, если надо разбудить , создавайте новый....
    – Денис
    8 мар 2019 в 17:36
  • у меня задача состоит в том, чтобы не убивать как раз потоки и не создавать новые, а использовать только существующие
    – i_burykin
    8 мар 2019 в 17:44
  • В чем разница? Более понятно, если менеджер потоков будет просто считать запущенные потоки, нежели ему нужно оценивать статус потоков. Если вы всё поставите на паузу, то ресурсы системы будут отьедены и у вас точно начнуться проблемы с остановкой приложения.
    – Денис
    8 мар 2019 в 18:09
  • Просто у меня задача в одновременном запуске потоков... При этом сами потоки создаются 1 раз. Далее просто должно начинаться все заново... Потоки перезапускаться не должны... вот я не совсем понимаю как это должно происходить
    – i_burykin
    8 мар 2019 в 19:20
  • 1
    Возможный дубликат вопроса: Как использовать поток несколько раз? 5 авг 2020 в 0:34

1 ответ 1

1

Дело в том, что при окончании метода run(), поток умирает, стек и память сразу освобождаются, и не возможно запустить один поток несколько раз -Как использовать поток несколько раз? , читайте. Проще все будет после await() написать вызов функции в while() , в которую впихнуть вопрос к пользователю - повторить или нет создание новых потоков.Если да , то в этой же функции создать новые потоки и тд. И также создать переменную Boolean что бы она регулировала цикл while() в главном потоке

1
  • Надеюсь помог :)
    – GinTasan
    8 мар 2019 в 22:49

Ваш ответ

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

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