package base;

/**
 * 安全终止线程
 */
public class StopThreadSafe {
	private static User u = new User();

	public static void main(String[] args) throws InterruptedException {
		new ReadObjectThread().start();
		while (true) {
			ChangeObjectThread t = new ChangeObjectThread();
			t.start();
			Thread.sleep(150);
			// stopMe()修改stopme标记
			t.stopMe();
		}
	}

	public static class User {
		private int id;
		private String name;

		public User() {
			super();
			id = 0;
			name = "0";
		}

		public int getId() {
			return id;
		}

		public void setId(int id) {
			this.id = id;
		}

		public String getName() {
			return name;
		}

		public void setName(String name) {
			this.name = name;
		}

		@Override
		public String toString() {
			return "User[id=" + id + ",name=" + name + "];";
		}
	}

	public static class ChangeObjectThread extends Thread {
		volatile boolean stopme = false;// 标记线程是否需要退出

		public void stopMe() {
			stopme = true;
		}

		@Override
		public void run() {
			while (true) {
				// 检查线程是否需要退出
				if (stopme) {
					System.out.println("exit by stop me");
					break;
				}

				synchronized (u) {
					int v = (int) System.currentTimeMillis();
					u.setId(v);
					try {
						Thread.sleep(100);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
					u.setName(String.valueOf(v));
				}
				Thread.yield();
			}
		}
	}

	public static class ReadObjectThread extends Thread {
		@Override
		public void run() {
			while (true) {
				synchronized (u) {
					if (u.id != Integer.parseInt(u.name)) {
						System.out.println(u.toString());
					}
				}
				Thread.yield();
			}
		}

	}
}