fullwaitmain.java

Java Thread Programming (Source

public class FullWaitMain extends Object {
	private FullWait fullwait;
	private Thread internalThread;
	private volatile boolean noStopRequested;

	public FullWaitMain(FullWait fw) {
		fullwait = fw;

		noStopRequested = true;
		Runnable r = new Runnable() {
				public void run() {
					try {
						runWork();
					} catch ( Exception x ) {
						x.printStackTrace(); 
					}
				}
			};

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

	private void runWork() {
		int count = 6;

		while ( noStopRequested ) {
			fullwait.setValue(count);
			System.out.println("just set value to " + count);
			count++;

			try {
				Thread.sleep(1000);
			} catch ( InterruptedException x ) {
				// reassert interrupt
				Thread.currentThread().interrupt();
			}
		}
	}

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

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

	public static void waitfor(FullWait fw, int val, long limit) 
				throws InterruptedException {

		System.out.println("about to waitUntilAtLeast(" + 
				val + ", " + limit + ") ... ");

		long startTime = System.currentTimeMillis();
		boolean retVal = fw.waitUntilAtLeast(val, limit);
		long endTime = System.currentTimeMillis();

		System.out.println("waited for " + 
				( endTime - startTime ) + 
				" ms, retVal=" + retVal + "\n---------------");
	}

	public static void main(String[] args) {
		try {
		 	FullWait fw = new FullWait(5);
			FullWaitMain fwm = new FullWaitMain(fw);

			Thread.sleep(500);

			// should return true before 10 seconds
			waitfor(fw, 10, 10000L); 

			// should return true right away --already >= 6
			waitfor(fw, 6, 5000L);

			// should return true right away
			//   --already >= 6 (negative time ignored)
			waitfor(fw, 6, -1000L);

			// should return false right away --not there 
			// yet & negative time
			waitfor(fw, 15, -1000L);

			// should return false after 5 seconds
			waitfor(fw, 999, 5000L);

			// should eventually return true
			waitfor(fw, 20, 0L);

			fwm.stopRequest();
		} catch ( InterruptedException x ) {
			System.err.println("*unexpectedly* interrupted " +
					"somewhere in main()");
		}
	}
}