并发：等到公共代码块完成

Question

我正在编写一个多线程服务器，需要处理客户端请求并在完成后将它们返回给客户端。

我有一个并发客户端连接对象列表，它将有效负载传递到一个公共队列。通过队列后，负载由服务器处理并生成响应。

我的问题是我不知道如何通知客户端服务器已完成处理。

这是处理客户端负载的线程，payLoad是一个BlockingQueue，之前是由客户端线程加载的：

 Thread messageHandling = new Thread() {
        public void run(){
            while(true){
                try{
                    Object payLoad= payLoads.take();
                    // Do some handling                        
                   // SEND REPLY BACCK TO THE CLIENT
                }
                catch(InterruptedException e){ }
            }
        }
    };

同时，在客户端，发生了以下情况：

{
   ...
payloads.add(payLoad)
/// Sleep until the server is done doing its logic with the payload

}

评论位是我遇到麻烦的地方。我不知道如何实现一种机制，客户端线程将等待直到请求被处理，一旦处理完毕，我不知道如何将回复发送回客户端。

我花了很多时间研究，查看消费者/生产者问题，等待/通知机制等，但似乎没有什么与这个特定问题相似。

任何帮助将不胜感激。

Answer 1

您需要在payloads 中的有效负载旁边存储客户端连接信息。

创建具有两个字段的类。其中一个将是您的有效负载，另一个是允许您识别您的客户的东西。

在您的// SEND REPLY BACCK TO THE CLIENT 中发送回复。无需等待/// Sleep until the server is done doing its logic with the payload

不知道您与客户沟通的方式，我无法给您更好的答案。

如果您使用套接字，“可以让您识别客户端的东西”将是套接字实例。

其他方法将使用SynchronousQueue。

您在// SEND REPLY BACCK TO THE CLIENT 中填写您的回复。

在/// Sleep until the server is done doing its logic with the payload 中，您获取响应（方法将阻塞，直到响应被放入缓冲区）。

通过与之前方法相同的有效负载传递缓冲区。