1回答
我有以下代码，其中包括将一些数据从C++中的PPL (并发运行时)库推送到并发队列对象。data;// data gets updated continuously#include <
浏览 19提问于2020-01-11得票数 1
3回答
从表中获取值作为引用
、、、
在c++中，它可以通过引用(&)或指针(*)来完成。在C#中有"ref“。如何从表中获取值并参照表进行更改？a={0}", a); //11 }}
例如在c+
浏览 2提问于2017-04-06得票数 1
回答已采纳
3回答
在基本线程池模式中，主线程将任务推送到请求队列。线程池以未指定的顺序执行任务，并在每个任务完成时向主事件循环发送通知。
在某些情况下，您可以从额外的吞吐量中受益，但只能按照指定的顺序使用已完成的任务。可以并发处理多个块并按顺序完成，但是主线程必须按照提交处理的顺序将每个处理块推送到音频流中。我的第一个想法是使用请求任务的某种线程安全队列(链接列表或deque)，让主线程在队列的顶部等待一个“已完成”的标志，然后断开它并使用数据。再想一想，这个问题一定已经解决了很多次了。
浏览 5提问于2017-07-17得票数 1
回答已采纳
1回答
你能不能不使用原语类型的并发队列？我在C++中使用ppl.h中的concurrent_queue对象，并按如下方式初始化我的队列： iQueue = new concurrency::concurrent_queue<int>; 我注意到，如果我像这样将int推送到队列中： iQueue->push(num); 然后尝试从另一个线程弹出它，我只能从队列中获得一个值-就是这样。并发队列不适用于像int这样的原语类型吗？
浏览 10提问于2020-01-23得票数 0
我使用向ActiveMQ队列发送/推送消息。我知道在侦听器开始处理该消息并发生任何异常后，该消息将被视为一种毒药药丸，并移到默认的acive的DLQ中。如果在发送时出现任何连接错误或任何其他错误，则发送/将该消息推送到队列时，该消息是否可能(即该消息将移动到默认的死信队列)？
浏览 1提问于2015-09-16得票数 0
回答已采纳
1回答
并发队列推送函数的C++返回值
、、、、
void pushFunction(LambdaFunction function) const { functionQueue.push(function); }基本上，我推送的函数是按顺序在不同的线程上运行的我可以将函数推送到并发队列中，该队列将在单独的线程上顺序运行我的函数。以便ex (伪代码)：auto intReturn = Logger.pushFunction([=]()->int { return x * y; });
将x*y推入<e
浏览 0提问于2013-01-29得票数 4
回答已采纳
因此，我们正在考虑使用windows服务或Server触发器。
服务可以轮询数据库，发送SMS /电子邮件，并删除已通知的行。
浏览 1提问于2011-07-14得票数 0
5回答
循环缓冲区队列中的无锁进度保证
、、、、
其中一个例子是在(著名的afaik)并发库( )中。我在研究liblfds中多生产者/多消费者限制队列的实现--实现非常简单，但我不能真正判断它是否应该是无锁的。
相关算法在中实现。我不清楚的原因是，“取得进展”的定义似乎含糊不清，因为如果观察到队列已满或空，推或弹可能总是失败。如果POP线程只是返回推送进行时队列是空的，则POP线程基本上会被阻塞，直到PUSH线程完成操作。如果推送线程死亡，或进入休眠1,000年，<em
浏览 3提问于2017-08-27得票数 30
回答已采纳
2回答
我的场景类似于管理员将通过网站/ wp8发布新的主题/队列，而工作人员应该在wp8中获得关于新添加的主题/队列的通知(通过推送通知)。此时，我已经准备好了所有的部分，如主题/队列创建、发送接收。意义管理器可以缓存主题并发布消息。然后，员工就必须订阅接收消息的主题，每次都要拉来检查，有什么新的吗？
所以我想让这个系统基于通知。我的意思是，每当在主题用户中添加任何内容时，都应该得到通知(通过推送通知)。那么，你能建议我如何实现这个目标吗？如果添加<em
浏览 4提问于2014-02-12得票数 2
回答已采纳
5回答
我正在使用队列在线程之间进行通信。我有一个阅读器和多个写入器线程。我的问题是，当我从队列中为读取器使用push/front/pop时，每次都需要锁定队列吗？while( i < numOfElements){ queue.pop();}
这个想法是，我想减少锁定代码的粒度，因为写线程只会写到队列的后面只要我获得了元素的数量，我就可以从队列中获取元素，或者我是否需要将front()和pop()也包含在锁中？
浏览 0提问于2010-10-27得票数 19
1回答
让线程本地队列具有计数器
、、、、
我有四个线程，它们有自己的私有队列和私有的'int计数‘成员，每当从程序线程生成任务时，都应该将其排队到线程的队列，其中线程中的’int计数‘最小。每当任务被推入队列时，当任务从队列中弹出时，私有'int计数‘应该增加1，而私有'int计数’应该减少1。因此，“int计数”是关于任务推送、pop操作的动态更改，而程序线程将将任务分派给队列，其计数最低(或第一个零)。。
这是程序的基本逻辑。我在linux多线程库中使用c++
浏览 3提问于2013-01-09得票数 1
2回答
在我的网站用户每次添加一些数据时，我都会在“默认”队列中添加一个任务(taskqueue.Task)来执行一些操作，包括修改文件("X")。更新
但是不确定该修改哪一个。
浏览 0提问于2014-07-20得票数 1
回答已采纳
我目前使用的是使用队列触发器的azure web作业，所以每当队列中有消息时，我就调用一个函数，该函数将执行15分钟的耗时任务(将数据推送到文档DB )，并且也能够执行，现在我的蔚蓝应用程序计划正在获得套接字异常du，web start正在自行重新启动，并且该函数在进入毒队列之前被重新尝试了多次。如何在web作业再次启动之前删除队列中的现有消息，以避免并发操作？
感谢任何帮助或指示
浏览 4提问于2017-06-09得票数 0
回答已采纳
1回答
1.push to the Queue我想在同一时间推拉队列，但我不确定(我没有在文档中找到，也没有找到实现)，队列是否保护了对同一内存访问的冲突 There is zero elements in the Queue -> Ipush and then I pull in the same time
我的问题是，如果队列没有保护它，有什么办法只锁定入口或出口的队列？
浏览 0提问于2019-04-02得票数 0
回答已采纳
在我的场景中，生产者向队列发送消息(与往常一样：)，但是其中一个使用者不时地关闭，因此我必须能够在使用者关闭时读取发送到该队列的所有消息。换句话说，我正在寻找消息或整个服务器的配置，它允许在用户重新连接后接收消息，而消息是预先发送的。
更准确地说，当客户端重新连接时，它无法接收队列中挂起的消息。我需要的是强制新连接的客户端接收队列中已经挂起的消息，以帮助其他客户端释放队列。
浏览 4提问于2017-01-13得票数 0
回答已采纳
目前的执行情况：
有一个队列，从队列中将消息推送到组件中，然后将消息放在DB中并进行进一步处理。它涉及许多DB调用，也需要更多的时间。所以需要用一种不同的方法来修改它。其中一种解决方案是:拥有一个以键作为头id的并发Hashmap，并将value作为并发链接消息队列。它通过执行器将分组在每个标头id下的单个队列发送给处理器。一旦特定的头id在映射中为空，它就会删除它。处理器-逐个轮询来自队列(ConcurrentLinkedQueue)的消息并对其进行
浏览 0提问于2018-08-06得票数 0
1回答
QPID C++客户端多线程优化
、、、、
我正在寻找一种最佳的方法来线程出一个C++ Apache客户端，以便在高消息流量下获得最佳性能。有几个文档很少的类用来与QPID代理接口。连接、会话、发件人和接收器。连接提供会话，会话提供发送方或接收方。客户端应用程序中将有多个线程上下文，需要将数据推送到上行链路队列之一。是否最好有一个会话、连接<em
浏览 1提问于2012-04-03得票数 1
1回答
原子电话。输入/输出操作
、、、、
我想使用无锁队列编写多线程安全记录器。日志线程将消息推送到队列中，记录器将弹出消息并发送到输出。我考虑如何解决这个问题--发送到输出。我希望尽可能避免使用互斥锁。因此，让我们假设我将使用C++流来写入文件/控制台。我们可以假设目标系统是Linux。
好的，写入流必须只是Unix write提供的系统调用的包装器(也许是高级包装器)。
浏览 5提问于2016-08-27得票数 1
回答已采纳
我管理一组客户端提供的事件接收器，每个接收器都订阅自己的事件流.每个接收器通常会将数据推送到自己的网络管道中，这意味着将事件推送到接收器中存在可利用的并发性。同时，我需要确保适当的事件排序。如果我的线程池将每个事件队列与单个线程关联起来，并将接受事件任务分派到该特定线程的任务队列，则这将是健壮的。我正在寻找一个基本的想法或一个可行的方法草图。
浏览 4提问于2012-10-18得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
