如何检查 ArrayBlockingQueue 是否被锁定或队列元素当前由线程处理？

发布于 2024-11-09 07:02:03 字数 482 浏览 0 评论 0原文

您好，我很好奇是否有办法检查 ArrayBlockingQuery 查询当前是否被锁定？原因：我有一个服务器，它监听套接字，接收参数，处理它们，然后将一些结果返回给客户端。该服务器（假设是服务器 A）在处理参数时与其他服务器（服务器 B）打开会话，然后将信息发送到 B。连接到 B 时只能创建一个会话，但 A 可以接受多个客户端连接。因为 ArrayBlockingQueue 用于存储参数，而其他一些线程通过队列运行并将它们一一发送到 B。

我需要执行该功能 - 当 ArrayBlockingQueue 为空并且当前时刻没有处理任何内容并且客户端数据发送到然后 A 立即处理 - 将数据发送到 B 服务器，处理来自 B 的响应，然后如果 ArrayBlockingQuery 不为空并且处理了某些内容，则 A 将响应返回给客户端，然后只需将参数添加到队列并将其他响应从 A 发送到客户端。这就是为什么我需要知道是否有办法检查 ArrayBlockingQueue 是否被锁定或队列元素当前由线程处理。

谢谢你！

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

烟花肆意 2024-11-16 07:02:03

有什么理由不只使用锁，因为它是为了保护一次只能在一个线程中使用的资源而设计的。

// in a client connection thread
lock.lock();
try {
    // use connection to server B
} finally {
    lock.unlock();
}

这确保服务器 B 一次仅在一个线程中使用，并且您不需要向队列添加任何内容。

不确定 ArrayBlockingQuery 是什么，谷歌也不知道。您的意思是 ArrayBlockingQueue 吗？

ArrayBlockingQueue 不会锁定很长时间，因此此信息不是很有用。但是您可以通过反射获得锁。

您似乎过度考虑了您的解决方案。

您希望确保服务器 B 一次仅获得一个连接，并且您正在使用队列来执行此操作，但是您想绕过这一点，但这意味着放弃一次一个的原则。

Is there any reason you don't just use a Lock as this is designed for protecting resources which can only be used in one thread at a time.

// in a client connection thread
lock.lock();
try {
    // use connection to server B
} finally {
    lock.unlock();
}

This ensures server B will only be use in one thread at a time and you don't need to add anything to a queue.

Not sure what a ArrayBlockingQuery is, nor does google. Do you mean ArrayBlockingQueue?

An ArrayBlockingQueue is not locked for very long, so this information isn't very useful. However you could obtain the lock via reflection.

You appear to be over thinking your solution.

You want to ensure that server B only get a connection one at a time, and you are using a queue to do this, however you want to way to by-pass this, but this means discarding your one at a time principle.

回复收藏 0 原文