merge my branch

src/BallVolume.java

@@ -0,0 +1,20 @@
+
+
+public class BallVolume extends ThreadSubscriber {
+
+    String in;
+    @Override
+    public void notifySubscriber() {
+        in = topic.getInput();
+        System.out.println("Ball Volume = " + execute());
+
+    }
+
+    @Override
+    public String execute() {
+        double PI = 3.14159265359;
+        double diameter = Double.parseDouble(in);
+        double res = (4.0/3.0) * PI * Math.pow(diameter, 3.0);
+        return String.valueOf(res);
+    }
+}

src/Fibonacci.java

@@ -0,0 +1,25 @@
+public class Fibonacci extends ThreadSubscriber{
+    String input;
+    @Override
+    public void notifySubscriber() {
+        input = topic.getInput();
+        System.out.println("Result of Fibonacci series at "+input+": "+execute());
+    }
+    @Override
+    public String execute() {
+        int num1 = 0;
+        int num2 = 1;
+        int sum = 0;
+        int n = Integer.parseInt(input);
+        if(n<=1)
+            sum = n;
+        for(int i=1 ; i < n ; i++) {
+            sum = num1 + num2;
+            num1 = num2;
+            num2 = sum;
+        }
+        String str = String.valueOf(sum);
+
+        return str;
+    }
+}

src/ISubscriber.java

@@ -1,4 +1,4 @@
-
 public interface ISubscriber {
-	public abstract void notifySubscriber(String input);
+    public abstract void notifySubscriber();
+    public abstract String execute();
 }

src/Main.java

@@ -1,17 +1,29 @@
 import java.util.Scanner;
 
 public class Main {
-	private static ISubscriber subscribers [] = {
-			new SimpleSubscriber(),
-			new ReallySimpleSubscriber(),
-	};
-	public static void main(String[] args) {
-		Topic mathTopic = new Topic();
-		for (ISubscriber sub : subscribers) {
-			mathTopic.addSubscriber(sub);
-		}
-		Scanner sc = new Scanner(System.in);
-		String input = sc.next();
-		mathTopic.dispatchEvent(input);
-	}
+
+  public static void main(String[] args) {
+
+      while (true) {
+          ThreadSubscriber subscribers[] = {
+                  new SphereCircumference(),
+                  new multiplicationSeries(),
+                  new BallVolume(),
+                  new twoPowerN(),
+                  new Fibonacci(),
+                  new SphereArea(),
+		  new SummationSeries()
+          };
+
+          Topic mathTopic = new Topic();
+          for (ThreadSubscriber sub : subscribers) {
+              mathTopic.addSubscriber(sub);
+              sub.setTopic(mathTopic);
+          }
+          Scanner sc = new Scanner(System.in);
+          String input = sc.nextLine();
+          mathTopic.setInput(input);
+          mathTopic.dispatchEvent();
+      }
+  }
 }

src/SphereArea.java

@@ -0,0 +1,20 @@
+
+public class SphereArea extends ThreadSubscriber{
+
+	String input;
+	@Override
+	public void notifySubscriber() {
+		input = topic.getInput();
+		System.out.println("Sphere Area = " + execute());
+	}
+
+	@Override
+	public String execute() {
+		double n = Integer.parseInt(input);
+		double pi = 3.14;
+		double sphereArea = 4 * pi * n * n;
+		return String.valueOf(sphereArea);
+	}
+
+
+}

src/SphereCircumference.java

@@ -0,0 +1,15 @@
+public class SphereCircumference extends ThreadSubscriber{
+    String input;
+    @Override
+    public void notifySubscriber() {
+        input =topic.getInput();
+        System.out.println("Sphere Circumference  = "+execute());
+    }
+
+
+    @Override
+    public String execute() {
+        double result = Double.parseDouble(input)*2*3.14159265359;
+        return String.valueOf(result);
+    }
+}

src/SummationSeries.java

@@ -0,0 +1,15 @@
+public class SummationSeries extends ThreadSubscriber {
+    String input;
+    @Override
+    public void notifySubscriber() {
+        input = topic.getInput();
+        System.out.println("SummationSeries = " + execute());
+    }
+
+    @Override
+    public String execute() {
+        int in = Integer.parseInt(input);
+        int res = in * (in + 1) / 2;
+        return String.valueOf(res);
+    }
+}

src/ThreadSubscriber.java

@@ -0,0 +1,24 @@
+public abstract class ThreadSubscriber extends Thread implements ISubscriber {
+    Topic topic;
+
+    public ThreadSubscriber(){
+
+    }
+
+    public Topic getTopic() {
+        return topic;
+    }
+
+    public void setTopic(Topic topic) {
+        this.topic = topic;
+    }
+
+    @Override
+    public abstract void notifySubscriber();
+    public abstract String execute();
+
+    @Override
+    public void run() {
+        notifySubscriber();
+    }
+}

src/Topic.java

@@ -2,24 +2,32 @@
 import java.util.List;
 
 public class Topic {
-
-	private List<ISubscriber> subscribers;
-
-	public Topic() {
-		subscribers = new ArrayList<ISubscriber>();
-	}
-
-	public void addSubscriber(ISubscriber sub) {
-		subscribers.add(sub);
-	}
-
-	public List<ISubscriber> getSubscribers() {
-		return subscribers;
-	}
-
-	public void dispatchEvent(String input) {
-		for (ISubscriber sub : this.getSubscribers()) {
-			sub.notifySubscriber(input);
-		}
-	}
+    private List<ThreadSubscriber> subscribers;
+    String input;
+
+    public Topic() {
+        subscribers = new ArrayList<ThreadSubscriber>();
+    }
+
+    public void addSubscriber(ThreadSubscriber sub) {
+        subscribers.add(sub);
+    }
+
+    public List<ThreadSubscriber> getSubscribers() {
+        return subscribers;
+    }
+
+    public String getInput() {
+        return input;
+    }
+
+    public void setInput(String input) {
+        this.input = input;
+    }
+
+    public void dispatchEvent() {
+        for (ThreadSubscriber sub : this.getSubscribers()) {
+            sub.start();
+        }
+    }
 }

src/multiplicationSeries.java

@@ -0,0 +1,21 @@
+import java.util.Scanner;
+
+public class multiplicationSeries extends ThreadSubscriber{
+    String input;
+    @Override
+    public void notifySubscriber() {
+        input =topic.getInput();
+        System.out.println("MultiplicationSeries = "+execute());
+    }
+
+
+    @Override
+    public String execute() {
+        int Number = Integer.parseInt(input);
+        int result = 1 ;
+        for (int i = 1; i <= Number; i++) {
+            result *= i;
+        }
+        return String.valueOf(result);
+    }
+}

src/twoPowerN.java

@@ -0,0 +1,25 @@
+public class twoPowerN extends ThreadSubscriber{
+    String input;
+    @Override
+    public void notifySubscriber() {
+        input =topic.getInput();
+        System.out.println("two power n  = "+execute());
+    }
+
+    @Override
+    public String execute() {
+    	  int exponent = Integer.parseInt(input);
+		int product = 2;
+
+		switch (exponent) {
+			case 0:
+		        product = 1;
+		        break;
+		}
+
+		for (int i = 1; i < exponent; i++) {
+			product = product * 2;
+		}
+
+		return String.valueOf(product) ;
+}