public class SyncBlock extends Object {
private Object longLock;
public SyncBlock() {
longLock = new Object();
}
public void doStuff() {
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 ) { }
print("about to relinquish exclusive access to " +
"longLock");
}
}
private static void print(String msg) {
String name = Thread.currentThread().getName();
System.err.println(name + ": " + msg);
}
private static Thread launch(
final SyncBlock sb,
String name
) {
Runnable r = new Runnable() {
public void run() {
print("in run()");
sb.doStuff();
}
};
Thread t = new Thread(r, name);
t.start();
return t;
}
public static void main(String[] args) {
try {
SyncBlock sb = new SyncBlock();
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();
}
}
}
为什么t2.interrupt(); 不能够终止线程T2
private Object longLock;
public SyncBlock() {
longLock = new Object();
}
public void doStuff() {
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 ) { }
print("about to relinquish exclusive access to " +
"longLock");
}
}
private static void print(String msg) {
String name = Thread.currentThread().getName();
System.err.println(name + ": " + msg);
}
private static Thread launch(
final SyncBlock sb,
String name
) {
Runnable r = new Runnable() {
public void run() {
print("in run()");
sb.doStuff();
}
};
Thread t = new Thread(r, name);
t.start();
return t;
}
public static void main(String[] args) {
try {
SyncBlock sb = new SyncBlock();
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();
}
}
}
为什么t2.interrupt(); 不能够终止线程T2
解决方案 »
免费领取超大流量手机卡,每月29元包185G流量+100分钟通话, 中国电信官方发货