package com.csdhsm.concurrent;

import java.util.Timer;

import java.util.TimerTask;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.TimeUnit;

class Blocker{

synchronized void waitingCall(){

try{

while(!Thread.interrupted()){

wait();

System.out.print(Thread.currentThread() + " ");

}

} catch (Exception e) {

//OK to exit this way

}

}

synchronized void prod(){

notify();

}

synchronized void prodAll(){

notifyAll();

}

}

class Task implements Runnable{

static Blocker blocker = new Blocker();

@Override

public void run() {

blocker.waitingCall();

}

}

class Task2 implements Runnable{

static Blocker blocker = new Blocker();

@Override

public void run() {

blocker.waitingCall();

}

}

public class NotifyVsNotifyAll {

public static void main(String[] args) throws InterruptedException {

ExecutorService exec = Executors.newCachedThreadPool();

for(int i = 0; i < 5; i++){

exec.execute(new Task());

}

exec.execute(new Task2());

Timer timer = new Timer();

timer.scheduleAtFixedRate(new TimerTask(){

boolean prod = true;

@Override

public void run() {

if(prod){

System.out.print("\nnotify()");

Task.blocker.prod();

prod = false;

}else{

System.out.print("\nnotifyAll()");

Task.blocker.prodAll();

prod = true;

}

}

}, 400, 400);//run every 0.4 second

TimeUnit.SECONDS.sleep(5); // run for a while

timer.cancel();

System.out.println("\nTimer camceled");

TimeUnit.MILLISECONDS.sleep(500);

System.out.print("Task2.blocker.prodAll()");

Task2.blocker.prodAll();

TimeUnit.MILLISECONDS.sleep(500);

System.out.println("\nShutting down");

exec.shutdownNow();//Interrupt all tasks

}

}