java - 并发链接队列 : How to implement a handler in Java?

Question

假设我们有两个线程通过 ConcurrentLinkedQueue 连接。我想要的是类似于队列上的处理程序的东西，以便一个线程知道另一个队列何时向队列添加了某些内容并轮询它。这可能吗？

Answer 1

通常，当一个线程上至少有一个生产者，并且另一个线程上至少有一个消费者时，就会使用 ConcurrentLinkedQueue。

消费者将在元素可用时立即处理元素，为此，队列上的读取操作会阻塞，有时会持续有限的时间。

根据应用程序，您可以有一个生产者和多个消费者，反之亦然。

阻塞完全满足您的要求(消费者线程知道何时插入元素)。

消费者线程阻塞并不是问题，除非是您的主进程线程或者除非您计划构建数百个并发消费者。

因此，如果您只是在专用线程上运行它，那么 Queue#take() 或 Queue#poll(long timeout,TimeUnit unit) 是您的 friend 。