class Ticket
{
private String name;
public int count=0;
public void set(String name)
{
  this.name=name;
}
public String get()
{
  return this.name;
}
}
class TicketRun implements Runnable
{
private Ticket tc;
boolean flag=false;
TicketRun(Ticket tc)
{
  this.tc=tc;
}
public void run()
{
  if(Thread.currentThread().getName()=="输入线程")
  {
   while(true)
   {
    synchronized(tc)
    {
     if(flag) try{wait();}catch (Exception e){}
   
     tc.set("HeMingHui");
     System.out.println(Thread.currentThread().getName()+tc.get()+tc.count++);
     flag=true;
     this.notify();
    }
   }
  }
  else
   while(true)
  {
   synchronized(tc)
   {
    if(!flag)try{wait();}catch(Exception e){}
  
    System.out.println(Thread.currentThread().getName()+tc.get()+tc.count);
    flag=false;
       this.notify();
   }
  }
}
}
class TicketDemo
{
public static void main(String[] args)
{
   Ticket tc=new Ticket();
   TicketRun p=new TicketRun(tc);
   Thread t1=new Thread(p,"输入线程");
   Thread t2=new Thread(p,"输出线程");
   t1.start();
   t2.start();
}
}
毕老师的程序分别建立两个类继承接口Runnable，分别实现线程单独的输入输出。而我用一个类继承Runnable，然后在里面判断输入输出线程所要执行的各自代码。但不知道问题出现在哪儿了

稍等一下哈！

一切答案都在下面的代码,请仔细看代码中的注释:

1. package heimabbs;
   
2. 
   
3. class Ticket {
   
4. 
   
5.         private String name;
   
6.         public int count = 0;
   
7. 
   
8.         public void set(String name) {
   
9.                 this.name = name;
   
10.         }
    
11. 
    
12.         public String get() {
    
13.                 return this.name;
    
14.         }
    
15. 
    
16. }
    
17. 
    
18. class TicketRun implements Runnable {
    
19. 
    
20.         private Ticket tc;
    
21.         boolean flag = false;
    
22. 
    
23.         TicketRun(Ticket tc) {
    
24.                 this.tc = tc;
    
25.         }
    
26. 
    
27.         public void run() {
    
28. // 判断字符串是否相同,当然是用equals()方法了.
    
29.                 if (Thread.currentThread().getName().equals("输入线程")) {
    
30.                         while (true) {
    
31.                                 synchronized (tc) {
    
32.                                         // 这里一定要将if改为while哦,要不然多个线程间很容易造成死锁.
    
33.                                         // 我就不说为什么了,用文字会说很多的,老毕的视频会详细讲到的.
    
34.                                         while (flag)
    
35.                                                 try {
    
36.                                                         // 锁的什么对象,就要用该对象来调用wait()方法.
    
37.                                                         tc.wait();
    
38.                                                 } catch (Exception e) {
    
39.                                                         e.printStackTrace();
    
40.                                                 }
    
41. 
    
42.                                         tc.set("HeMingHui");
    
43.                                         System.out.println(Thread.currentThread().getName()
    
44.                                                         + tc.get() + tc.count++);
    
45.                                         flag = true;
    
46. 
    
47.                                         // 锁的什么对象,就要用该对象来调用notify()方法.
    
48.                                         tc.notify();
    
49.                                 }
    
50.                         }
    
51.                 } else
    
52.                         while (true) {
    
53.                                 synchronized (tc) {
    
54.                                         // 这里一定要将if改为while哦,要不然多个线程间很容易造成死锁.
    
55.                                         // 我就不说为什么了,用文字会说很多的,老毕的视频会详细讲到的.
    
56.                                         while (!flag)
    
57.                                                 try {
    
58.                                                         // 锁的什么对象,就要用该对象来调用wait()方法.
    
59.                                                         tc.wait();
    
60.                                                 } catch (Exception e) {
    
61.                                                         e.printStackTrace();
    
62.                                                 }
    
63. 
    
64.                                         System.out.println(Thread.currentThread().getName()
    
65.                                                         + tc.get() + tc.count);
    
66.                                         flag = false;
    
67. 
    
68.                                         // 锁的什么对象,就要用该对象来调用notify()方法.
    
69.                                         tc.notify();
    
70.                                 }
    
71.                         }
    
72.         }
    
73. 
    
74. }
    
75. 
    
76. public class TicketDemo {
    
77. 
    
78.         public static void main(String[] args) {
    
79.                 Ticket tc = new Ticket();
    
80.                 TicketRun p = new TicketRun(tc);
    
81.                 Thread t1 = new Thread(p, "输入线程");
    
82.                 Thread t2 = new Thread(p, "输出线程");
    
83.                 t1.start();
    
84.                 t2.start();
    
85.         }
    
86. 
    
87. }

复制代码

把this.notify();改成tc.notify();就好了， 要明确解开哪个锁，还有判断字符串要用equlas方法

马镱洵 发表于 2012-9-7 13:31
一切答案都在下面的代码,请仔细看代码中的注释:

非常感谢你能帮我解答问题。但是上面的程序又出现了死锁，原因出现在什么地方了？
毕老师说当被操作的公共数据判断的时候需要加同步
但是线程中如果有操作的公共资源中有数据变化时是不是也要同步啊，
例如：打印变量x，System.out.println(x);x--;如果在某一时刻要打印的x的值是87，但是运行该数据的线程t1被运行该数据的线程t2抢走，并且改变了x值，那么等到转换t1的时候是不是打印改变之后的x值，那么在输出变化的x值时应该会重复吧

何明辉 发表于 2012-9-7 17:28
非常感谢你能帮我解答问题。但是上面的程序又出现了死锁，原因出现在什么地方了？
毕老师说当被操作的公 ...

"但是上面的程序又出现了死锁，原因出现在什么地方了？"

不是死锁,而是死循环,是最外面那个while造成的.



"但是线程中如果有操作的公共资源中有数据变化时是不是也要同步啊"

我很肯定的回答,是.

马镱洵 发表于 2012-9-7 17:54
"但是上面的程序又出现了死锁，原因出现在什么地方了？"

不是死锁,而是死循环,是最外面那个while造成的. ...

为什么不能实现交替打印了，只是输入一行数据之后程序就挂那儿了

何明辉 发表于 2012-9-7 21:07
为什么不能实现交替打印了，只是输入一行数据之后程序就挂那儿了

1. package heimabbs;
   
2. 
   
3. class Ticket {
   
4. 
   
5.         private String name;
   
6.         public int count = 0;
   
7. 
   
8.         public void set(String name) {
   
9.                 this.name = name;
   
10.         }
    
11. 
    
12.         public String get() {
    
13.                 return this.name;
    
14.         }
    
15. 
    
16. }
    
17. 
    
18. class TicketRun implements Runnable {
    
19. 
    
20.         private Ticket tc;
    
21.         boolean flag = false;
    
22. 
    
23.         TicketRun(Ticket tc) {
    
24.                 this.tc = tc;
    
25.         }
    
26. 
    
27.         public void run() {
    
28.                 // 判断字符串是否相同,当然是用equals()方法了.
    
29.                 if (Thread.currentThread().getName().equals("输入线程")) {
    
30.                         while (true) {
    
31.                                 synchronized (tc) {
    
32.                                         // 这里一定要将if改为while哦,要不然多个线程间很容易造成死锁.
    
33.                                         // 我就不说为什么了,用文字会说很多的,老毕的视频会详细讲到的.
    
34.                                         while (flag)
    
35.                                                 try {
    
36.                                                         // 锁的什么对象,就要用该对象来调用wait()方法.
    
37.                                                         tc.wait();
    
38.                                                 } catch (Exception e) {
    
39.                                                         e.printStackTrace();
    
40.                                                 }
    
41. 
    
42.                                         tc.set("HeMingHui");
    
43.                                         System.out.println(Thread.currentThread().getName()
    
44.                                                         + tc.get() + tc.count++);
    
45.                                         flag = true;
    
46. 
    
47.                                         // 锁的什么对象,就要用该对象来调用notify()方法.
    
48.                                         tc.notify();
    
49.                                 }
    
50.                         }
    
51.                 } else
    
52.                         while (true) {
    
53.                                 synchronized (tc) {
    
54.                                         // 这里一定要将if改为while哦,要不然多个线程间很容易造成死锁.
    
55.                                         // 我就不说为什么了,用文字会说很多的,老毕的视频会详细讲到的.
    
56.                                         while (!flag)
    
57.                                                 try {
    
58.                                                         // 锁的什么对象,就要用该对象来调用wait()方法.
    
59.                                                         tc.wait();
    
60.                                                 } catch (Exception e) {
    
61.                                                         e.printStackTrace();
    
62.                                                 }
    
63. 
    
64.                                         System.out.println(Thread.currentThread().getName()
    
65.                                                         + tc.get() + tc.count);
    
66.                                         flag = false;
    
67. 
    
68.                                         // 锁的什么对象,就要用该对象来调用notify()方法.
    
69.                                         tc.notify();
    
70.                                 }
    
71.                         }
    
72.         }
    
73. 
    
74. }
    
75. 
    
76. public class TicketDemo {
    
77. 
    
78.         public static void main(String[] args) {
    
79.                 Ticket tc = new Ticket();
    
80.                 TicketRun p = new TicketRun(tc);
    
81.                 Thread t1 = new Thread(p, "输入线程");
    
82.                 Thread t2 = new Thread(p, "输出线程");
    
83.                 t1.start();
    
84.                 t2.start();
    
85.         }
    
86. 
    
87. }

复制代码

你看,没问题啊,我给你的代码不存在你说的死锁问题.

何明辉 发表于 2012-9-7 21:07
为什么不能实现交替打印了，只是输入一行数据之后程序就挂那儿了

你好好把你的代码和我给你的代码对照一下,你一定有错误代码的地方.

马镱洵 发表于 2012-9-7 23:29
你看,没问题啊,我给你的代码不存在你说的死锁问题.

应该是死循环，我在dos命令行下运行的数据的，成许总是输入第一行后就停滞不动了，没有实现交替打印的效果。

何明辉 发表于 2012-9-7 23:39
应该是死循环，我在dos命令行下运行的数据的，成许总是输入第一行后就停滞不动了，没有实现交替打印的效 ...

你看吧,交替打印的啊.

何明辉 发表于 2012-9-7 23:39
应该是死循环，我在dos命令行下运行的数据的，成许总是输入第一行后就停滞不动了，没有实现交替打印的效 ...

你把代码修改后要重新编译的哦.
干脆你把代码发上来看看.