java交替打印奇偶数问题,会出现2个线程都wait阻塞了
代码如下:
import static java.lang.System.out;
/**
* 交替打印奇偶数
*
* @author ***
* @create 2018-11-13 19:48
*/
public class Test0001 {
public static Object OBJ = new Object();
public static int i;
public static class MyThread1 extends Thread {
@Override
public void run() {
while( true ) {
synchronized( OBJ ) {
out.println(Thread.currentThread().getName() + " enter---- " + i);
if( i % 2 == 0 ) {
out.println(Thread.currentThread().getName() + " " + i++);
try {
out.println(Thread.currentThread().getName() + " wait");
OBJ.wait();
out.println(Thread.currentThread().getName() + " wait over");
} catch( InterruptedException e ) {
e.printStackTrace();
}
} else {
out.println(Thread.currentThread().getName() + " notify");
OBJ.notify();
}
out.println(Thread.currentThread().getName() + "leave--- " + i);
}
}
}
}
public static class MyThread2 extends Thread {
@Override
public void run() {
while( true ) {
synchronized( OBJ ) {
out.println(Thread.currentThread().getName() + " enter---- " + i);
if( i % 2 == 1 ) {
out.println(Thread.currentThread().getName() + " " + i++);
out.println(Thread.currentThread().getName() + " notify");
OBJ.notify();
} else {
try {
out.println(Thread.currentThread().getName() + " wait");
OBJ.wait();
out.println(Thread.currentThread().getName() + " wait over");
} catch( InterruptedException e ) {
e.printStackTrace();
}
}
out.println(Thread.currentThread().getName() + "leave--- " + i);
}
}
}
}
public static void main( String[] args ) {
Thread t1 = new MyThread1();
Thread t2 = new MyThread2();
t1.start();
try {
Thread.sleep(111);
} catch( InterruptedException e ) {
e.printStackTrace();
}
t2.start();
}
}
执行结果如下:
Thread-0 enter---- 0
Thread-0 0
Thread-0 wait
Thread-1 enter---- 1
Thread-1 1
Thread-1 notify
Thread-1leave--- 2 //语句1
Thread-1 enter---- 2 //语句2
Thread-1 wait
Thread-0 wait over
Thread-0leave--- 2
Thread-0 enter---- 2
Thread-0 2
Thread-0 wait
然后程序就卡住了····
好奇的是,为什么 Thread-1 leave(语句1) 之后 Thread-1 又立马 enter(语句2) 了,按道理 Thread-1 leave之后不是应该 Thread-0 enter吗。。。求赐教!!
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
发布评论
评论(3)
我来回答一波。
你可以先将 Thread2 的代码做以下两种修改,一种是:
public static class MyThread2 extends Thread {
@Override
public void run() {
while( true ) {
synchronized( OBJ ) {
out.println(Thread.currentThread().getName() + " enter---- " + i);
if( i % 2 == 1 ) {
out.println(Thread.currentThread().getName() + " " + i++);
out.println(Thread.currentThread().getName() + " notify");
OBJ.notify();
} else {
try {
out.println(Thread.currentThread().getName() + " wait");
OBJ.wait();
out.println(Thread.currentThread().getName() + " wait over");
} catch( InterruptedException e ) {
e.printStackTrace();
}
}
out.println(Thread.currentThread().getName() + "leave--- " + i);
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
另外一种是:
public static class MyThread2 extends Thread {
@Override
public void run() {
while( true ) {
synchronized( OBJ ) {
out.println(Thread.currentThread().getName() + " enter---- " + i);
if( i % 2 == 1 ) {
out.println(Thread.currentThread().getName() + " " + i++);
out.println(Thread.currentThread().getName() + " notify");
OBJ.notify();
} else {
try {
out.println(Thread.currentThread().getName() + " wait");
OBJ.wait();
out.println(Thread.currentThread().getName() + " wait over");
} catch( InterruptedException e ) {
e.printStackTrace();
}
}
out.println(Thread.currentThread().getName() + "leave--- " + i);
}
Thread.yield();
}
}
}
这两种改法你分别运行一下,会发现第一种改法运行以后能得到你想要的结果。
而第二种改法,答案是不一定,并且最终极大可能还是会把两个线程堵死。
你的代码的运行结果跟你的预期不符,主要你忽视了两点:
- CPU时间片
- wait被notify后,不会立即获得锁。
Java 的对象锁的实现采用的是Monitor机制,具体机制如下,你也可以参考我写过的一篇文章:
当一个线程需要获取 Object 的锁时,会被放入 EntrySet 中进行等待,如果该线程获取到了锁,成为当前锁的 owner。如果根据程序逻辑,一个已经获得了锁的线程缺少某些外部条件,而无法继续进行下去(例如生产者发现队列已满或者消费者发现队列为空),那么该线程可以通过调用 wait 方法将锁释放,进入 wait set 中阻塞进行等待,其它线程在这个时候有机会获得锁,去干其它的事情,从而使得之前不成立的外部条件成立,这样先前被阻塞的线程就可以重新进入 EntrySet 去竞争锁。
你的Thread2调完notify后,Thread1等到Thread2释放锁以后,它还得和 Thread2 站在同一条起跑线上去竞争锁,所以没有绝对地说Thread2释放锁以后,Thread1一定就轮到它获得锁。
你的代码每次都运行相同的结果,原因主要在于 Thread2 会比 Thread1 更容易重新获得锁,因为Thread2的CPU时间片极大可能还没用完。
我们上面的修改,第一种修改是让 Thread2 sleep 一秒,这绝对能让Thread1 有充足的时间获取锁,所以运行结果会如你所预期。
第二种修改是让 Thread2 让出 CPU 时间片,但是同样,CPU 在重新选择线程运行的时候,至少会有一半的机会还是会选中 Thread2。
以上。希望能帮到你。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
参考这里:
https://github.com/crossoverJ...