进程与线程

开发平台：

Java

InterruptibleSyncBlock.java：源码内容

							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();
		}
	}
}

						