2

我有一个静态信号量实例。

    Semaphore semaphore = new Semaphore(1);

现在我有两个线程（发送线程和接收线程）

发送线程：

public class SendingThread implements Runnable {

    private Semaphore semaphore;

    public SendingThread(Semaphore semaphore){
        this.semaphore = semaphore;
    }

    @Override
    public void run() {
        try {
            System.out.println("1");
            Thread.sleep(4000);
            this.semaphore.acquire();

        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            e.printStackTrace();
        }   
    }
}

和接收线程：

public class RecievingThread implements Runnable {

    private Semaphore semaphore;

    public RecievingThread(Semaphore semaphore){
        this.semaphore = semaphore;
    }
    @Override
    public void run() {
        System.out.println("2");
         this.semaphore.release();
            System.out.println("3");
    }
}

当我根据我的理解启动这两个线程时，接收线程将等待4 秒，直到发送线程通知 它接收线程可以继续。这意味着 System.out.println("3");将延迟 4 秒打印，但是当我运行此代码时，所有三个值都会立即打印。为什么？

我错过了什么吗？

4

1 回答 1

3

Anew Semaphore(1)有1 个初始许可证，因此允许一个立即acquire通过。此外，由于始终release允许 a ，因此两个线程都立即进行。

要强制一件事先于另一件事发生，您可以使用new Semaphore(0). 这将强制线程调用acquire等待线程执行release。

于 2012-06-21T22:26:55.607 回答