JAVA使用类在线程之间同步操作

Question

我目前正在尝试创建一种可靠的 UDP 协议，其中我的服务器向我的客户端发送每个 1024 字节的数据包，当它完成发送/接收周期时，服务器等待并且客户端通过 TCP 向服务器发送命令告诉它没有收到哪些数据包（我使用前 2 个字节作为数据包 ID [短类型]），然后服务器收到远程类的通知并发送丢失的数据包。

private void waitUntilNotified() {
    synchronized (this) {
        try {
            System.out.println("Waiting..." + new Date());
            waiting = true;
            wait();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("Stop waiting");
    }
}

public void notifyThis(){
    synchronized (this) {
        if(waiting){
            waiting = false;
            notify();
            System.out.println("Notified " + new Date());
            return;
        }
    }
}

我的问题是，有时在本地测试中，命令在服务器开始等待之前到达，因此导致它永远等待。

如果有一种万无一失的方法可以确保即使触发notifyThis()的命令在服务器触发waitUntilNotified()函数之前出现，它仍然会通知它并更改等待状态？

如果有任何不清楚的地方，请发表评论，我会尽力解释。

TL:DR，我正在寻找一种仅在服务器启动到 wait() 之后才调用 notify() 的方法，即使调用是在它开始等待之前进行的

Answer 1

在我看来，您真正需要的是更高级别的并发原语。以下是一些可能性：

• Semaphore .... 很有可能
• CyclicBarrier
• CountDownLatch

或者可能是某种Queue 或Deque。

---

问题（对我们而言）是我们无法看到您实际使用等待/通知方法的方式，因此不清楚您真正需要什么。

但作为一个一般原则，从长远来看，识别和使用适当的更高级别的并发类比尝试从基本构建块实现自己的并发更好。

而且......正如@DB 所说......在 UDP 之上实现自己的“可靠”传输正在重新发明轮子。 TCP 是显而易见的替代方案，如果您这样做是为了获得“比 TCP 更好”的性能，还有其他替代方案。