interruptiblesyncblock.java

java多线程编程实例_Source

public class InterruptibleSyncBlock extends Object {
	private Object longLock;
	private BooleanLock busyLock;

	public InterruptibleSyncBlock() {
		longLock = new Object();
		busyLock = new BooleanLock(false);
	}

	public void doStuff() throws InterruptedException {
		print("about to try to get exclusive access " +
				"to busyLock");
		busyLock.waitToSetTrue(0);

		try {
			print("about to try to get exclusive access " +
					"to longLock");
			synchronized ( longLock ) {
				print("got exclusive access to longLock");
				try { 
					Thread.sleep(10000); 
				} catch ( InterruptedException x ) { 
					// ignore
				}
				print("about to relinquish exclusive access " +
						"to longLock");
			}
		} finally {
			print("about to free up busyLock");
			busyLock.setValue(false);
		}
	}

	private static void print(String msg) {
		String name = Thread.currentThread().getName();
		System.err.println(name + ": " + msg);
	}

	private static Thread launch(
				final InterruptibleSyncBlock sb, 
				String name
			) {

		Runnable r = new Runnable() {
				public void run() {
					print("in run()");
					try {
						sb.doStuff();
					} catch ( InterruptedException x ) {
						print("InterruptedException thrown " +
								"from doStuff()");
					}
				}
			};
		
		Thread t = new Thread(r, name);
		t.start();

		return t;
	}

	public static void main(String[] args) {
		try {
			InterruptibleSyncBlock sb = 
					new InterruptibleSyncBlock();
	
			Thread t1 = launch(sb, "T1");
			Thread.sleep(500);

			Thread t2 = launch(sb, "T2");
			Thread t3 = launch(sb, "T3");

			Thread.sleep(1000);

			print("about to interrupt T2");
			t2.interrupt();
			print("just interrupted T2");

		} catch ( InterruptedException x ) {
			x.printStackTrace();
		}
	}
}