Refactor code for thread termination

Author: abhinav-nath

README.md

@@ -12,7 +12,7 @@ Simple and easy to understand code examples for most of the Concurrent APIs prov
     - [Callable](./src/com/codecafe/concurrency/thread/basics/designathread/CallableDemo.java)
     - [ExecutorService](notes/executorservice.md) - [[code](./src/com/codecafe/concurrency/executorservice/ExecutorServiceDemo.java)]
   - [Thread States](./notes/thread-states.md) - [[code](./src/com/codecafe/concurrency/thread/basics/designathread/ThreadStates.java)]
-  - [Stop a Thread](./src/com/codecafe/concurrency/thread/basics/StopAThreadInMiddle.java)
+  - [Thread Termination](./src/com/codecafe/concurrency/thread/basics/Main.java)
 - [Thread Signalling](./src/com/codecafe/concurrency/threadsignalling)
 - [Daemon Thread](./notes/daemon-thread.md) - [[code](./src/com/codecafe/concurrency/thread/daemonthread)]
 

src/com/codecafe/concurrency/thread/basics/StopAThreadInMiddle.java renamed to src/com/codecafe/concurrency/thread/basics/Main.java

@@ -1,14 +1,15 @@
 package com.codecafe.concurrency.thread.basics;
 
-class MyThread1 extends Thread {
+class LongComputationTask implements Runnable {
 
+  @Override
   public void run() {
-    // Intentional infinite loop
+    // Intentional infinite loop to simulate a long computation task
     for (; ; ) {
       // Returns true if the thread is interrupted
-      if (interrupted()) {
+      if (Thread.currentThread().isInterrupted()) {
         // You are supposed to roll back or reverse the operation in progress and stop
-        System.out.println("Thread is interrupted hence stopping...");
+        System.out.println("\nThread is interrupted hence stopping...");
         // Terminates the loop
         break;
       }
@@ -18,14 +19,14 @@ public void run() {
 
 }
 
-public class StopAThreadInMiddle {
+public class Main {
 
   public static void main(String[] args) {
-    MyThread1 th = new MyThread1();
+    Thread th = new Thread(new LongComputationTask());
     th.start();
 
     try {
-      Thread.sleep(10);
+      Thread.sleep(50);
     } catch (InterruptedException e) {
       e.printStackTrace();
     }