一个多线程分别打印abc的有关问题
日期：2014-05-20 浏览次数：21070 次
一个多线程分别打印abc的问题
运行这段代码，前面可以打印两三次abc，然后就卡住了，初步估计应该都进入wait了，但是不明白为什么，求指导
------解决方案--------------------
你理解下
运行这段代码，前面可以打印两三次abc，然后就卡住了，初步估计应该都进入wait了，但是不明白为什么，求指导
public class TestDemo {
public static void main(String[] args) {
final Locker p = new Locker();
Task11 a = new Task11(p);
Task21 b = new Task21(p);
Task31 c = new Task31(p);
Thread one = new Thread(a);
one.start();
Thread two = new Thread(b);
two.start();
Thread three = new Thread(c);
three.start();
}
}
class Task11 implements Runnable {
private Locker obj;
public Task11(Locker p){
this.obj = p;
}
@Override
public void run() {
for(int i = 0; i < 5; i++){
synchronized (obj) {
if(obj.num != 0){
try {
obj.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}else{
System.out.println("a");
obj.num = 1;
obj.notifyAll();
}
}
}
}
}
class Task21 implements Runnable {
private Locker obj;
public Task21(Locker p){
this.obj = p;
}
@Override
public void run() {
for(int i = 0; i < 5; i++){
synchronized (obj) {
if(obj.num != 1){
try {
obj.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}else{
System.out.println("b");
obj.num = 2;
obj.notifyAll();
}
}
}
}
}
class Task31 implements Runnable {
private Locker obj;
public Task31(Locker p){
this.obj = p;
}
@Override
public void run() {
for(int i = 0; i < 5; i++){
synchronized (obj) {
if(obj.num != 2){
try {
obj.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}else{
System.out.println("c");
obj.num = 0;
obj.notifyAll();
}
}
}
}
}
class Locker {
int num = 0;
}------解决方案--------------------
你理解下
public class TestDemo {
public static void main(String[] args) {
final Locker p = new Locker();
Task11 a = new Task11(p);
Task21 b = new Task21(p);
Task31 c = new Task31(p);
Thread one = new Thread(a);
one.start();
Thread two = new Thread(b);
two.start();
// Thread three = new Thread(c);
// three.start();
}
}
class Task11 implements Runnable {
private Locker obj;
public Task11(Locker p){
this.obj = p;
}
@Override
public void run() {
for(int i = 0; i < 5; i++){
synchronized (obj) {
if(obj.num != 0){
try {
obj.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}else{
System.out.println("a");
obj.num = 1;
免责声明： 本文仅代表作者个人观点，与爱易网无关。其原创性以及文中陈述文字和内容未经本站证实，对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。
