java信号量的问题

Question

我是java新手，我只是想通过下面的例子来感受一下这种语言。谁能告诉我为什么下面的程序只显示：

     calling prod
     calling cons

import java.util.concurrent.*;

public class Trial5 {
    static public void main(String[] arg){
            new Prod();
            new Cons();
    }
}

class Q {
    static Semaphore semc = new Semaphore(0);
    static Semaphore semp  = new Semaphore(1);
    static int q[];
}

class Cons implements Runnable{
    Thread t;
    Cons () {
            System.out.println("calling cons");
            Thread t = new Thread();
            t.start();
    }
    public void run () {
            System.out.println("Running semc");
            try {
                System.out.println ("Waiting for Data.Acquiring semc");
                Q.semc.acquire ();
                if(Q.q[0] != 0) {
                    System.out.println(Q.q[0]);
                    Q.q[0] = 0;
                } else {
                    wait ();
                }
                System.out.println ("Releasing semc");
                Q.semc.release ();
            }
            catch (Exception e) {
            System.out.println (e.getMessage());
         }
     }
 }

 class Prod implements Runnable {
      Thread t;
      Prod () {
           System.out.println ("calling prod");
           t = new Thread ();
           t.start ();
      }
      public void run() {
           System.out.println ("running semp");
           try {
                System.out.println ("Waiting for Data.Acquiring semp");
                Q.semp.acquire ();
                if (Q.q[0] == 0) {
                     System.out.println ("setting value semp");
                     Q.q[0] = 10;
                } else {
                     Thread.sleep(100);
                }
                System.out.println ("Releasing semp");
                Q.semp.release ();
           }
           catch (Exception e) {
                System.out.println (e.getMessage());
           }    
      }
 }

Answer 1

你的问题不在于信号量，而在于你的线程。您的 run 方法没有执行，因为您正在实例化 Thread 的新实例，该实例不知道您创建的类并运行这些实例，而不是对您创建的类执行任何操作。所以你的 run 方法永远不会被调用。

具体来说，像这样的行：

Thread t = new Thread();
t.start();

没有引用它们所包含的类。它们只是创建一个新的 Thread 对象，该对象只有默认的 run 方法，然后启动它。

此站点提供了线程如何运行的示例（通过扩展线程或通过实现 Runnable）。不过，您将必须重新构建一些代码才能使其正常工作。尽管简单地更改要读取的行可能会起作用，

Thread t = new Thread(this);

但这是一个坏主意，因为您将在对象的构造函数仍在运行时将对象作为值传递。更好的想法是让 main 方法构造每个对象，然后使用它们来启动线程运行。

Answer 2

此外：

1. 始终在
   try-finally 块。所以无论怎样
   碰巧你总是释放
   信号量，否则会出现死锁
   必然会发生。
2. 您正在调用“wait()”（这是 Runnable（继承自 Object）实例的一个方法），但您不能调用，因为您不拥有锁。有关详细信息，请参阅 Monitor
3. Thread.sleep(100) 实际上会抛出 InterruptedException：捕获它并重新中断线程，因为抛出 InterruptedException 时中断标志会被清除。有关此主题的更多信息，请参阅处理 InterruptedException

Answer 3

您需要执行

t = new Prod();

并

t= new Cons();

查看此处以获取进一步参考：
http://www.exampledepot.com/egs/java.lang/BasicThread.html