package javaUtil;

import java.util.Observable;
import java.util.Observer;

class Watcher implements Observer{
	@Override
	public void update(Observable o, Object arg) {
		if ((int) arg <100){
			System.out.println("Внимание! Обнаружен валютчик! Зафиксирована продажа ниже установленного курса!");
			((BeingWatched) o).PosaditVTurmu();
		}
	}
}

class BeingWatched extends Observable{
	void counter(int count){
		for(; count>=0; count--){
			int b = sell();
			setChanged();
			notifyObservers(new Integer(b));
			
			try {
				Thread.sleep(0);
			} catch (InterruptedException e) {
				count=-1;
			}
		}
	}
	
	int sell(){
		int a =(int) (Math.random()*530);
		System.out.println("Продан доллар по курсу - " + a);
		return a;
	}
	
	void PosaditVTurmu(){
		System.out.println("Валютчик отправлен в тюрьму!");
		Thread.currentThread().interrupt();
	}
}


public class Observer_ {
	public static void main(String[] args) {
		BeingWatched observered = new BeingWatched();
		Watcher abservering = new Watcher();
		observered.addObserver(abservering);
		observered.counter(100);
	}
}

package javaUtil;

import java.util.Timer;
import java.util.TimerTask;

public class Timer_ {
	public static void main(String[] args) {
		Timer myTimer = new Timer();
		NewTask tsk = new NewTask();  
		System.out.println("Запуск задачи по таймеру(сначала ждем 2 секунд, потом каждые 2 секунды):");
		myTimer.schedule(tsk, 2000, 2000);
	}
}

class NewTask extends TimerTask{
	int j = 3;
	
	@Override
	public void run() {
		int i = 10;
		while (i>0){
			i--;
			System.out.println("Hello " + i);
		}
	
		j--;
		if (j == 0){
			cancel();
			System.out.println("Поток задания - демон ? - " + Thread.currentThread().isDaemon());
			System.out.println("Имя потока - " + Thread.currentThread().getName());
			System.out.println("Состояние потока - " + Thread.currentThread().getState());
		}	
	}
}