ThredsSample.java

ThreadsSample.java

  class CountingThread extends Thread {

    private final int maxCount;
    private final CountingThread terminationThread;
    private boolean stopped = false;

    public CountingThread(int maxCount, CountingThread terminationThread) {
      this.maxCount = maxCount;
      this.terminationThread = terminationThread;
    }

    @Override
    public void run() {
      int counter = 0;
      while (!stopped && counter < maxCount) {
        try {
          Thread.sleep(500);
          System.out.println(getName()  + ":" + counter);
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
        counter++;
      }

      if (terminationThread != null) {
        terminationThread.requestStop();
      }
    }

    public void requestStop() {
      stopped = true;
    }
  }




  @Test
  public void testThreadTermination() {

    CountingThread t1 = new CountingThread(15, null);
    CountingThread t2 = new CountingThread(5, t1);
    t1.start();
    t2.start();


    try {
      t1.join();
      t2.join();
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
  }