1

我有一个通过套接字与客户端通信的 java 服务器应用程序。每个客户端请求都在一个新线程中处理。但是对于某些请求，我需要同步两个客户端。

例子：

  • 客户端 A 向服务器 S 发送请求。
  • S上的线程S1接受A的请求。
  • S1 将此请求通知客户端 B（通过 GoogleCloudMessaging）。
  • S1 现在应该阻塞
  • 客户端 B 接收到来自 S 的信息并向 S 发送请求。
  • S上的线程S2接受B的请求。
  • S1 应该立即发布并从 S2 获取消息
  • S1 将答案发送给客户端 A

我知道Lock Condition机制，但这在这里不起作用，因为我不知道创建线程时的条件。我需要类似的东西：

// Pseudo Code
// on the S1 Thread, first argument beeing a signal ID, second a timeout
s1.waitForSignal("clientB", 10000);
// and on the S2 Thread to continue S1
SignalSender.send("clientB");

在Java中有这样的可能吗？我的问题还有其他解决方案吗？

4

1 回答 1

0

您的问题似乎是您没有可以调用wait/的共享引用notify（更不用说您可以使用的共享锁定条件）。

好吧，首先，这两个线程之间已经共享了一些东西：即，在您的情况下， string "ClientB"。如果你有这个，你需要做的就是将该字符串映射到两个类都可以访问的位置中的单个引用。

最简单的实现是在某处保存一个静态地图字段，然后以某种方式用监视器对象填充它：

public final class Monitors {

    private Monitors() {}

    private static final Map<String, Object> monitors = new HashMap<String, Object>();

    static { monitors.put("ClientB", new Object()); }

    public static Object get(String key) { return monitors.get(key); }

}

当然，您可能想要编写一个适当的服务来管理此映射，并可能在内部使用锁和条件。此外，一个好主意是将等待和信令功能封装在服务本身中，然后像这样使用它monitorService.waitForSignalsFrom("ClientB")：

于 2013-07-22T19:50:54.757 回答