java言語スレッド処理

Question

前提・実現したいこと

スレッドを使用したプログラムです。1秒間でエンターキーを押した数を表示するプログラムを作成し実行したのですが、実行すると、下のようなエラー文が出てしまい、かつカウントが１回のみで強制終了してしまいます。どの部分を修正すればうまく実行できるのか、よろしければアドバイスをお願いします。

発生している問題・エラーメッセージ

Enter:
Enter:
Exception in thread "main" java.lang.IllegalThreadStateException
        at java.base/java.lang.Thread.start(Thread.java:793)
        at Sample.main(Sample.java:44)
1

該当のソースコード

import java.io.*;

class Counter{
    private int count = 0;
    public synchronized void add(){
        try{

            int temp = count;
            Thread.sleep(1000);
            count = temp + 1;
        }
        catch(InterruptedException e){

        }
    }

    public int getCount(){
        return count;
    }
}

class Worker extends Thread{
    Counter counter = new Counter();

    public void run(){
        counter.add();
        System.out.println(counter.getCount());

        return;
    }

}

class Sample{
    public static void main(String[] args) throws NumberFormatException{
        Worker worker = new Worker();
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));

        while(true){
             System.out.print("Enter: ");
            try{
                if((br.readLine()).equals("")){
                    worker.start();
                }
            }
            catch(IOException e){
                System.out.println("error");
            }
        }

    }
}

Answer 1

スレッドは、1回実行したものは再利用できません。

Answer 2

「1秒間でエンターキーを押した数を表示」であれば、別スレッドは 1 秒後に表示する 1 つだけで済むはずです。

---

上で別スレッドで表示としましたが、分かり難いかもしれませんのでメインスレッドで表示するものにしました。

package teratail_java.q367984;

import java.io.*;

//1秒後に停止する
class Worker extends Thread {
  private int count = 0;
  private boolean end = false;
  public void run() {
    try {
      Thread.sleep(1000);
      System.out.println("Enter to End.");
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    end = true;
  }
  void countUp() { if(!end) count ++; }
  int getCount() { return count; }
}

class Sample {
  public static void main(String[] args) {
    Worker worker = new Worker();
    try (BufferedReader br = new BufferedReader(new InputStreamReader(System.in));) {
      System.out.print("Enter to Start.");
      br.readLine();

      worker.start();
      System.out.println("Hit Enters.");
      while (worker.isAlive()) {
        br.readLine();
        worker.countUp();
      }
    } catch (IOException ignore) {
    }
    System.out.println("count="+worker.getCount());
  }
}

Comments

[keishinitta]

１秒後に表示する１つだけとはどういうことでしょうか？

[jimbe]

なぜお作りのプログラムでスレッドが必要なのかと言えば、入力と時間計測を同時に行う必要があるからだと思います。
であれば、メインのスレッドと新たに作るスレッドの二つがあれば、一方で入力を処理し、もう一方で時間を計るように担当を分けるだけです。

表示をどちらでするかは単なる選択で、時間を計る方で表示のほうが見た目は分かり易いかも知れないということで、「いや分かり難い」と言われればそうかも知れません。

Answer 3

threadクラスは１度終了したら、再度そのオブジェクトを使用することはできません。

なので、RunnableクラスとExecututerServiceクラスを使って、こう書くかな自分なら。
動かしてないので、ご自身で試してください。

import java.io.*;

class Counter{
    private int count = 0;
    public synchronized void add(){
        try{

            int temp = count;
            Thread.sleep(1000);
            count = temp + 1;
        }
        catch(InterruptedException e){

        }
    }

    public int getCount(){
        return count;
    }
}

// ここをthreadクラスからRunnableクラスに変える
class Worker implements Runnable {
    Counter counter = new Counter();

    public void run(){
        counter.add();
        System.out.println(counter.getCount());

        return;
    }

}

class Sample{
    public static void main(String[] args) throws NumberFormatException{
        // ExecutorServiceのオブジェクトを生成
        ExecutorService exec = Executors.newSingleThreadExecutor();
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));

        while(true){
             System.out.print("Enter: ");
            try{
                if((br.readLine()).equals("")){
                    // Workerオブジェクトを生成して別スレッドで実行する
                    exec.submit(new Worker());
                }
            }
            catch(IOException e){
                System.out.println("error");
            }
        }

    }
}