Boost：阻塞直到队列中有另一个项目
共有1个答案
您希望执行一个有趣的操作：您希望在一个无锁队列上执行一个阻塞操作，这与无锁队列的目的正好相反。
使用一个使用互斥体和一个条件变量的正常阻塞队列。这很容易，而且是一种更标准的方法。
在许多情况下，您实际上为lockfree付出了性能代价，因为您保证队列不持有任何锁，即使在最坏的情况下也是如此。
-
问题内容： 我在一个非常简单的生产者-消费者场景中使用 java.util.concurrent.BlockingQueue 。例如，此伪代码描述了使用者部分： 到目前为止，一切都很好。在阻塞队列的javadoc中，我读到： BlockingQueue本质上不支持任何类型的“关闭”或“关闭”操作，以指示将不再添加任何项目。这些功能的需求和使用往往取决于实现。例如，一种常见的策略是让生产者插入特殊的
-
目前我们有LinkedBlockingQueue和Con的LinkedQueue。 LinkedBlockingQueue可以有界，但它使用锁。 ConcurrentLinkedQueue不使用锁，但它不受限制。而这并不是阻碍投票的原因。 显然，我不能有一个既阻塞又无锁的队列（无等待或非阻塞或其他东西）。我不要求学术定义。 有人知道一个队列实现，它基本上是无锁的（不在热路径中使用锁），空时阻塞（不
-
blpop key1...keyN timeout 从左到右扫描返回对第一个非空list进行lpop操作并返回，比如blpop list1 list2 list3 0 ,如果list不存在list2,list3都是非空则对list2做lpop并返回从list2中删除的元素。如果所有的list都是空或不存在，则会阻塞timeout秒，timeout为0表示一直阻塞。当阻塞时，如果有client对ke
-
我编写了一个简单的类，我计划将其扩展为客户端套接字编程应用程序的一部分。类涉及一个BlockingQueue（我从这里复制了代码：相当于Java的BlockingQueue的C++）。当我创建了下面的包装类的一个实例后，我打算让它生成一个单独的线程，该线程只需执行BlockingQueue上阻塞的printer（）函数，直到有一个或多个字符串可用，然后它只需将字符串打印到控制台窗口。在我的预期应用
-
我正在编写一个有3个线程的程序。一个读取一个文本文件并将单词输入到大小为2的ArraylistBlockingQueue中。下一个获取该列表并反转其中的每个其他单词。最后一个线程获取单词并将它们写入一个新的文本文件。 我所有的东西都在工作，除了我不知道如何中断和停止我的线程。程序写入文本文件，但从未结束。 主要方法 输入 反向类@重写公共void run（）{ 输出代码@覆盖公共无效run（）{
-
下面是两种主要的方法。 代码：