innerselfrun.java

java多线程编程实例_Source

public class InnerSelfRun extends Object {
	private Thread internalThread;
	private volatile boolean noStopRequested;

	public InnerSelfRun() {
		// other constructor stuff should appear here first ...
		System.out.println("in constructor - initializing...");

		// just before returning, the thread should be created and started.
		noStopRequested = true;

		Runnable r = new Runnable() {
				public void run() {
					try {
						runWork();
					} catch ( Exception x ) {
						// in case ANY exception slips through
						x.printStackTrace(); 
					}
				}
			};

		internalThread = new Thread(r);
		internalThread.start();
	}

	private void runWork() {
		while ( noStopRequested ) {
			System.out.println("in runWork() - still going...");

			try {
				Thread.sleep(700);
			} catch ( InterruptedException x ) {
				// Any caught interrupts should be habitually re-asserted
				// for any blocking statements which follow.
				Thread.currentThread().interrupt(); // re-assert interrupt
			}
		}
	}

	public void stopRequest() {
		noStopRequested = false;
		internalThread.interrupt();
	}

	public boolean isAlive() {
		return internalThread.isAlive();
	}
}