import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class Test {
	static int _ret = 0;
	static ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(
			5);
	static ScheduledFuture<?> s;

	public static void main(String[] args) {
//		Runnable r = new Runnable() {
//			@Override
//			public void run() {
//				System.out.println("Hello Scheduled Thread Pool Excutor "
//						+ _ret);
//				_ret++;
//
//				if (3 <= _ret) {
//					boolean removeSuccess = excutor.remove(this);
//					System.out.println(removeSuccess);
//				}
//			}
//		};
		s = executor.scheduleAtFixedRate(new Runnable() {
			@Override
			public void run() {
				System.out.println("Hello Scheduled Thread Pool Excutor "
						+ _ret);
				_ret++;

				if (3 <= _ret) {
					s.cancel(false);
					// boolean removeSuccess = excutor.remove((Runnable)s);
					// System.out.println(removeSuccess);
					executor.purge();
				}
			}
		}, 1, 1, TimeUnit.SECONDS);
//		System.out.println(Integer.valueOf("xiaYinCun".hashCode()));
	}
}

class n {
	String name = "";
	String id = "";

	public n(String name, String id) {
		this.name = name;
		this.id = id;
	}
}