//Esta clase se encarga de administrar y definir el comportamiento del proceso thread que refresca el
//y obtiene datos del servidor.
 
//Para ejecutar un thread ponemos new threadChat("Nombre del thread").start();
package procesos;
 
/**
 *
 * @author Andoni Diaz
 */
public class threadChat extends Thread {
    public static String datoObtenido;
    public static int contador;
    public threadChat(String str) {
        super(str);
    }
    public void run() {
    for(int i = 0; i < 10; i++) {
 
        datoObtenido = "Hola";
        contador=1;
        contador++;
 
            }
    }
    public static void main(String args[]) {
       threadChat thread = new threadChat("Prueba");
       thread.setPriority(10);
       thread.start();
       thread.stop();
        System.out.println(datoObtenido + contador);
    }
}
 

/**
 *
 * @author Andoni Diaz
 */
public class threadChat extends Thread {
    private     String datoObtenido;
    private int contador =0;
    private boolean run = true;
    public threadChat(String str) {
        super(str);
    }
    public boolean isRun() {
		return run;
	}
	public void setRun(boolean run) {
		this.run = run;
	}
	public synchronized void run() {
    while(run){
        datoObtenido = "Hola";
        System.out.println(datoObtenido+" ->"+contador);
        contador++;
        try {
    		wait();
    	  } catch (InterruptedException e) {
    		// TODO Auto-generated catch block
    		e.printStackTrace();
        }
    }System.out.println("Hilo Detenido");}
    public static void main(String args[]) {
       threadChat thread = new threadChat("Prueba");
       thread.setPriority(10);
       thread.start();
       int max = 10;
       while(true){
       	try {
			Thread.sleep(500);
		} catch (InterruptedException e) {e.printStackTrace();
		}
		synchronized (thread) {
			thread.notify();
				if(thread.contador==max)
					thread.setRun(false);
		   }
       }
    }
}

/**
 *
 * @author L-eyer
 */
class mainClass{
	//---------------------------------------------------
	public static void main(final String[] args){
		threadForTasks tasks = new threadForTasks();
		new ThreadControl(tasks);
		tasks.start();		
		}
	}
class threadForTasks extends Thread{
	private int     task     = 0    ;
	private boolean active   = true ;
	private boolean received = false;
 
	public int  getTask() {return task;}
	public void setTask(int index) {this.task = index;}
 
	@Override public synchronized void run(){
		while(active){
			try {
				Thread.sleep(500);
			} catch (InterruptedException e) {e.printStackTrace();
			}
			System.out.println("-----------------------------------");
			System.out.println(":Performing the task : "+task);
			System.out.println("-----------------------------------");
			task++;
				received = true;
					try {
						wait();
					} catch (InterruptedException e1) {e1.printStackTrace();
					}
		}
	}
	public boolean isReceived() {
		return received;
	}
	public void setReceived(boolean received) {
		this.received = received;
	}
	public threadForTasks() {super("Thread For Tasks");
	}
}
        public class ThreadControl extends Thread{
	private threadForTasks thread;
	private boolean activated  = true ;
	@Override public synchronized void run(){
		while(activated){
			try {if(thread.isReceived()){
			       System.out.println("\n"+getName()+"->Obtained:Task "+thread.getTask()+"");
					synchronized(thread){
						System.out.println("->Restarting.."+thread.getName());
						Thread.sleep(1000);
						       thread.setReceived(false);
								thread.notify();
							}
					}
				Thread.sleep(20);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
 
	}
	public boolean isActivated() {
		return activated;
	}
	public void setActivated(boolean activated) {
		this.activated = activated;
	}
	public ThreadControl(threadForTasks threadNro1) {super("Thread Control");
		this.thread = threadNro1;
		start();
	}