C/C++无锁(或非阻塞)环形缓冲区,它覆盖了最旧的数据？
在云计算领域中，C/C++无锁（或非阻塞）环形缓冲区是一种高效的数据传输和存储方式，它可以在不使用锁（Lock）的情况下实现线程安全的数据读写操作。环形缓冲区是一种循环使用的缓冲区，它可以在不需要重新分配内存的情况下实现数据的循环使用。
C/C++无锁（或非阻塞）环形缓冲区的优势：
- 高效：无锁（或非阻塞）环形缓冲区可以避免锁带来的性能开销，提高数据传输和存储的效率。
- 线程安全：无锁（或非阻塞）环形缓冲区可以在多线程环境下安全地读写数据，避免了数据竞争和死锁等问题。
- 灵活：无锁（或非阻塞）环形缓冲区可以根据需要动态调整缓冲区大小，满足不同场景下的数据传输需求。
应用场景：
- 数据传输：无锁（或非阻塞）环形缓冲区可以在数据传输过程中实现高效的数据传输，例如在网络编程中实现高性能的数据传输。
- 音视频处理：无锁（或非阻塞）环形缓冲区可以在音视频处理过程中实现高效的数据传输和存储，例如在音视频播放器中实现缓冲区管理。
- 实时数据处理：无锁（或非阻塞）环形缓冲区可以在实时数据处理过程中实现高效的数据传输和存储，例如在实时数据分析和处理中实现数据缓存。
推荐的腾讯云相关产品：
- 腾讯云云服务器：腾讯云云服务器提供了高性能、高可用、可扩展的计算服务，可以满足不同场景下的计算需求。
- 腾讯云对象存储：腾讯云对象存储提供了高效、安全、可扩展的数据存储服务，可以满足不同场景下的数据存储需求。
- 腾讯云内容分发网络：腾讯云内容分发网络可以实现高效的数据传输和加速，可以在音视频、网页等场景下实现高性能的数据传输。
产品介绍链接地址：
相关·内容
2回答
我已经理解了环形缓冲区背后的想法，以及它如何帮助不必在过程中移动元素。然而，我很好奇如何最好地处理线程安全的可变长度缓冲区，并提供与环形缓冲区类似的优点？我们是否可以在达到容量时将大小加倍，并让一个线程在互斥锁中执行复制？这个可变大小的缓冲区仅仅是一个实现为线程安全的队列吗？最好的方法是什么，这种并发读/写访问的替代解决方案的优缺点是什么？
浏览 22提问于2019-06-30得票数 0
回答已采纳
1回答
生产者和消费者优化
、、、、
我正在用Qt编写一个具有OnReceive(整数值)事件的C++程序。它捕获整数值并将其转换为std：：push_back。在另一个工作线程上，我可以访问这个向量，我可以设置一个信号量来等待20个值，然后我就可以处理它们了。
我想做一些优化。
我的问题是，如何将缓冲区或向量分割为0-4，5-10，11-19三个部分，例如，只要向量中有5个值(例如0到4)，第二个worker就开始处理它们，而第一线程仍然继续获取其余的值。
通过这种方式，我想在我的线程之间有一个重叠。因此它们不需要以串行方式运行。
谢谢。
浏览 0提问于2017-08-10得票数 0
我在OSX/达尔文中有以下程序结构：
生产者线程生成数据并将其提供给循环缓冲区。
使用者实时CoreAudio线程将数据从循环缓冲区呈现到DAC.
它们通过dispatch_semaphores进行协调。
生产者线程参数可以由GUI (GLUT，非Cocoa)或MIDI控制。
就控制生产者的GUI而言，一切都很顺利。
但是，midiReadProc( )回调是在它自己的实时线程上进行的，它既不应该控制生产者线程，也不应该通知它，但是MIDI数据应该以某种方式传递给主线程，生产者线程应该从主线程中排队并更新。
有没有任何方法可以做到这一点，而不太具体的OSX？
提前谢谢。
浏览 3提问于2016-01-30得票数 0
回答已采纳
3回答
我正试图找到一种方法，在Linux上用C语言用多核处理器编写一个没有锁的IPC应用程序。
让我们假设我有进程1和进程2写入FIFO或共享内存。然后进程3和进程4将从共享内存或FIFO读取。
用无锁算法能做到这一点吗？
非常感谢您的指导。
浏览 0提问于2012-07-20得票数 9
2回答
我正试图在我的大学里开发一个用于科学目的的地图应用程序。因此，我获得了大量的瓦片(256x256)。我可以访问它们并将它们保存到单独QThread中的QImage中。我的问题是，我如何才能在独立的QThread (而不是GUI主线程)中将QImage加载到纹理中呢？或者更好的是给我一个如何处理这个问题的提示。
我想过多线程OpenGL，但我也需要OpenGL选择，并且我没有发现任何对that.#有用的东西
如果您觉得，我非常感谢在Linux上编译的一切，请告诉我任何有用的示例代码:)
Note1:我使用的是基于事件的渲染，所以只有当场景改变时，它才会被重绘。Note2: OSG不是一个选项，对
浏览 2提问于2010-01-22得票数 2
回答已采纳
应用程序登录配置-
<appender name="stash"
class="net.logstash.logback.appender.LogstashAccessTcpSocketAppender">
<destination>localhost:5001</destination>
<!-- encoder is required -->
<encoder>
<pattern>%d{dd/MM/YY HH:mm:ss.SSS} - %
浏览 2提问于2016-03-28得票数 2
4回答
我是多线程编程的新手，我只知道最常见的生产者-消费者-队列。我正在使用boost c++库，我不知道使用boost::lockfree::queue还是使用使用mutex和condition\_variable的std::queue的包装类更好。
使用无锁数据结构更好，使用基于mutex和condition\_variables的简单实现更好
浏览 0提问于2013-04-29得票数 13
回答已采纳
1回答
我为多个客户端编写了客户机服务器聊天(使用非阻塞套接字多路复用i/o )。
现在我已经修正了bufferSize (例如，length = 64)。我想用环形缓冲区在客户端和服务器之间进行数据交换。我还编写了一些函数(缓冲区初始化、popFront和pushBack)来编写缓冲区。
如何才能实现这一想法？例如，我想我需要两个结构:第一个结构具有缓冲区长度和指向另一个缓冲区中的数据的指针，第二个缓冲区具有数据。但现在我不知道该拿它怎么办。你能给我个建议吗？谢谢。
下面是我的ringBuffer结构和函数(我认为函数bufferSize是错误的)：
struct ringBuffer
{
浏览 4提问于2017-05-24得票数 1
回答已采纳
在Windows下使用libusb (在Windows中不完全支持轮询/选择支持)，是否有一种方法可以检查某个USB端点上挂起的字节，即检查下面的读取是否成功(并读取一个或多个字节)？
浏览 6提问于2013-08-20得票数 2
回答已采纳
1回答
我正在用Linux编写一个多线程应用程序。
内核中没有RT补丁，但我使用具有优先级的线程。
在检查执行printf所需的时间时，我每次测量时都会测量不同的值，尽管它是在最高优先级的线程中完成的：
if(clock_gettime(CLOCK_MONOTONIC, &start))
{ /* handle error */
}
for(int i=0; i< 1000; i++)
printf("hello world");
if(clock_gettime(CLOCK_MONOTONIC, &end))
{
/* handle error
浏览 63提问于2018-06-04得票数 0
5回答
无锁和无阻塞有什么区别？
、、、
在数据结构同步的上下文中，有人能澄清“无锁”和“非阻塞”之间的区别吗？这些术语似乎被许多人互换使用，但我还不确定其中是否隐藏着一些微妙的区别。
我的意思是，无锁是“没有锁的”，而非阻塞更像是保证进程。我怀疑其中一个意味着另一个，但不是另一个，我不确定。
欢迎参考。
浏览 1提问于2009-07-28得票数 3
回答已采纳
1回答
我使用Boost的无锁队列作为生产者-消费者队列。我希望每个使用者线程在队列为空时阻塞，当队列中有更多数据时醒来，或者任何生产者终止。但是Boost似乎没有提供阻塞的pop，只提供立即返回的pop。
消费者应如何等待数据可用？
浏览 1提问于2015-04-12得票数 2
回答已采纳
在输出模式下运行的一个典型的PyAudio回调是：
def callback(ignored, frame_count, time_info, status):
buffer = <fill and return a buffer with frame_count samples of data>
return (buffer, pyaudio.paContinue)
我还没有试过，但我很肯定，如果我在回调返回后立即开始修改buffer，那么它会在播放数据时破坏数据--是吗？
那么问题是:是否有一种方法可以知道PyAudio何时完成了缓冲区的播放？如果是这样的话，我
浏览 4提问于2016-05-01得票数 2
回答已采纳
2回答
给定一个数据序列(带有副本)，沿数据序列移动固定大小的窗口，并在每次迭代时在窗口中查找模式，其中最旧的数据将被删除，并将新数据插入到窗口中。
我的想法是:使用哈希表，key是数据，key的data是数据在窗口中出现的频率。
在第一次迭代中，迭代窗口中的每个数据并将其放到哈希表中，同时计算每个数据的频率。之后，遍历哈希表并返回频率最高的数据。对于接下来的每一次迭代，在哈希表中搜索最旧的数据，如果它在哈希表中，则将其频率减少1，如果它变为0，则使用新数据来替换旧数据。否则，只需将新数据插入hahstable。
它是O(n * m)，其中n是数据序列大小，m是窗口大小。缺点是:哈希表的大小不是固定
浏览 2提问于2012-03-24得票数 0
回答已采纳
4回答
我正在寻找一种方法来实现无锁队列数据结构，支持单个生产者和多个消费者。我看过Maged和Michael Scott (1996)的经典方法，但他们的版本使用了链表。我想要一个使用有界循环缓冲区的实现。使用原子变量的东西？
顺便说一句，我不确定为什么这些经典方法是为需要大量动态内存管理的链表设计的。在多线程程序中，所有内存管理例程都是序列化的。我们不是因为将无锁方法与动态数据结构结合使用而失去了它们的好处吗？
我正在尝试使用Intel 64位体系结构上的pthread库在C/C++中对此进行编码。
谢谢你，Shirish
浏览 1提问于2010-04-24得票数 17
1回答
目前我们有LinkedBlockingQueue和ConcurrentLinkedQueue。
LinkedBlockingQueue可以是有界的，但它使用锁。
ConcurrentLinkedQueue不使用锁，但它不是有界的。而且它不会阻塞，这使得它很难轮询。
显然，我不能让一个既阻塞又无锁的队列(等待自由或非阻塞或其他)。我不要求学术上的定义。
有没有人知道一个队列实现，它基本上是无锁的(不在热路径中使用锁)，在空的时候阻塞(不需要忙碌等待)，并且是有界的(满的时候阻塞)？堆外解决方案也是受欢迎的。
我听说过LMAX Disruptor，但它看起来一点也不像队列。
我也很高兴知道非通用的
浏览 0提问于2017-09-29得票数 3
我正在寻找一个相当于英特尔的的模块在锈蚀。我找到了一些箱子：
甚至
我觉得他们都在做类似的事情，但是在他们的文档中，他们似乎在使用不同的算法来实现。
虽然我对C++编程不太了解，但我确信tbb的concurrent_queue是一个非常快速的MPMC队列实现。如果只在Mutex中包装队列容器(由我的一个朋友进行测试)，则无法接近该性能。
由于效率(包括延迟和吞吐量)是我关心的主要问题，我应该在Rust中使用什么？队列可以是有界的，也可以是无界的，我可能需要获取-释放排序。
浏览 0提问于2018-03-18得票数 2
1回答
因此，锁自由度是指您可以保证整个系统都在进步，尽管有些线程可能会饿死。因此，基于CAS的实现将提供这一保证。
然后，如果所有其他线程都挂起，那么obstruction-freedom就是保证一个线程完成的时候。
你能给出一个简单的例子，说明一种非无锁的无障碍算法吗？
谢谢!
浏览 2提问于2017-09-29得票数 2
回答已采纳
2回答
互斥与原子变量
、、、
原子操作--有效地同时或根本不执行Ex：java.util.concurrent.atomic.AtomicInteger的操作。
互斥-防止同时访问共享资源Ex：synchronized
使用互斥方法，SynchronizedCounter是线程安全的，
class SynchronizedCounter {
private int c = 0;
public synchronized void increment() {
c++;
}
public synchronized void decrement() {
c--;
浏览 4提问于2017-12-02得票数 2
1回答
我看到环缓冲区非常有用的速度，如果你有一个已知的最大缓冲长度，他们有很多意义。假设在有流数据的场景中，但是播放流被暂停，并在后台持续缓存。
当需要缓存的数据超过环缓冲区的大小时，您如何处理环缓冲区？还是有更好的缓冲方法呢？
浏览 0提问于2016-02-09得票数 1
我的场景是这样的:用户与GUI元素交互，音频回调函数读取UI设置的变量，计算示例并将样本存储在缓冲区(或任何数据结构)中，然后由UI读取缓冲区并绘制一个波形(每秒60次绘制循环)。
现在，根据我读过的一些内容( Linux音频开发列表中的一个线程，和)，我需要某种可以同时读写而不需要锁的数据结构，或者需要某种跨线程通知系统来传递变量。
但是，我看到的 使用了C++ std库中的普通向量，它们从一个线程读取，从另一个线程进行写入，当我运行程序时，它们运行得很好。
在哪种情况下，我需要使用无锁的数据结构来进行这种跨线程通信？
如果我添加了另一个线程，如MIDI或OSC回调函数，该函数接收网
浏览 6提问于2012-02-13得票数 5
回答已采纳
我想知道PortAudio的PaStreamFinishedCallback中哪些操作是安全的。我知道，通常情况下，尝试在PaStreamCallback上阻塞播放的操作不是一个好主意，因为这可能会导致用户或其他应用程序的音频流出现弹出/故障。同样的限制是否也适用于PaStreamFinishedCallback？我想最终我会好奇这个回调是否也会在操作系统的音频线程上被调用。
或者，是否有像Pa_StopStream这样的函数会阻塞，直到回调返回paComplete/paAbort，但不会导致停止？这实际上对我的使用是理想的，因为我有一个线程，这是我清理的正确位置。我知道我可以通过让我的回调信
浏览 1提问于2017-12-29得票数 1
1回答
我在我的内核可加载模块中使用printk来记录系统调用的参数。对于每个系统调用，都会使用几个printks来打印变量，它们以"\t“作为分隔符出现。为了将内核日志缓冲区中的数据重定向到system /var/ log /messages之外的其他文件，我使用"klogd -f“绕过syslog接口。获取的日志数据是每个系统调用一行。然而，在对数据进行分析后，我发现存在两个问题。
问题1:数据可能丢失。
问题2:一个系统调用的数据与属于另一个系统调用的数据混合在一起，可能在中间。
问题1:内核日志缓冲区溢出是否会导致数据丢失，从而覆盖缓冲区中最旧的日志？如果是这样，如何克服它？我
浏览 8提问于2012-10-04得票数 3
1回答
我有以下场景。 我们在K8s的云中对我们的应用程序进行了负载测试。我们的入站消息是通过Kafka发送的，我们正在给Kafka回信。我们的架构是这样的: Kafka线程将消息推送到disruptor (阻塞等待策略，512大小)，业务线程将消息从disruptor中取出进行处理。为了模拟负载，我们在Kafka主题(4个分区)中设置了应用程序未运行时的关闭500K消息。然后，我们启动应用程序来测量负载。 我们看到的是，disruptor完全填满了剩余的0容量，然后开始耗尽，这种情况一次又一次地继续下去。 这是正确的行为，还是我们以错误的方式使用颠覆者？请分享你的想法？
浏览 35提问于2020-07-21得票数 0
2回答
我一直在阅读关于非阻塞算法及其在并发编程中的使用的随机链接。有没有在C/C++中使用非阻塞算法的有用的库，哪些类型的并发数据结构可以从非阻塞算法的使用中获益最多？谢谢。
浏览 0提问于2010-11-09得票数 3
回答已采纳
1回答
我对声音编程和ALSA很陌生。我想创建一个小应用程序，例如，当使用snd_pcm_writei(...)将数据框架写入ALSA时，该应用程序将打印到控制台。这有可能吗?如果有，怎么做？目前，我正在考虑将回调注册到ALSA，因此当应用程序调用snd_pcm_writei(...)时，就会执行回调。但我不确定这是怎么回事。
浏览 1提问于2019-06-25得票数 0
回答已采纳
2回答
无锁的定义
、、、、
有三种不同类型的“无锁”算法。“行动中的并发性”中给出的定义如下：
Obstruction-Free:如果所有其他线程都暂停了，那么任何给定的线程都将在一定数量的步骤中完成其操作。
锁-无锁:如果多个线程正在数据结构上操作，那么在有限制的步骤之后，其中一个线程将完成它的操作。
等待-免费:在数据结构上操作的每个线程都将在一定数量的步骤中完成其操作，即使其他线程也在数据结构上操作。
赫伯·萨特在他的演讲中说
非正式地说，“无锁”≈不使用互斥“≈”。
我不明白为什么基于锁的算法不能进入上面给出的无锁定义。下面是一个简单的基于锁的程序：
#include <iost
浏览 13提问于2022-05-28得票数 6
回答已采纳
2回答
在一些关于算法的文章中，有些使用了单词lockfree，有些使用了lockless。lockless和lockfree有什么区别？谢谢!
更新
第5.2节--“Linux中的无锁环缓冲区*”，这是使用单词“无锁”的一个例子
浏览 0提问于2013-12-09得票数 12
回答已采纳
1回答
改进多线程代码设计以防止争用条件
、、、、
我遇到了一个问题，我不确定它是否能以我想要解决的方式解决。我的种族状况有问题。
我有一个项目运行作为一个C++ dll (主机)。然后，我有了第二个C#进程，它使用C++/CLI与主引擎(编辑器)通信。
编辑器将引擎窗口作为子窗口承载。其结果是子窗口接收输入消息异步(请参阅RiProcessMouseMessage())。通常，只有当我调用window->PollEvents();时才会发生这种情况。
main engine loop {
RiProcessMouseMessage(); // <- Called by the default windows message
浏览 16提问于2020-12-23得票数 1
我想知道Fober等人的论文中提出的先进先出队列是否是多消费者和生产者先进先出队列。如果不是，哪一个是记录最好的多消费者和生产者FIFO队列？
谢谢
浏览 0提问于2010-06-05得票数 3
回答已采纳
1回答
我对这两个概念有点困惑。
wiki上无锁的定义：
一个非阻塞算法是无锁的，如果有保证的系统范围内的进展。
非阻塞的定义：
如果任何线程的故障或挂起不能导致另一个线程的失败或挂起，则称为非阻塞算法。
我认为spinlock是无锁的，或者至少是非阻塞的。但现在我不确定了。因为从定义上来说，"spinlock is not lock-free"对我来说也是有意义的。例如，如果保持自旋锁的线程被挂起，那么它将导致其他线程在外面旋转。因此，根据定义，spinlock甚至不是非阻塞的，更不用说无锁了.
我现在很困惑。有人能解释清楚吗？
浏览 4提问于2016-12-14得票数 7
回答已采纳
1回答
从sctp套接字进行并发读取是线程安全的。SCTP堆栈可能使用一些同步原语(例如互斥)来实现它。我的问题是(sctp)套接字是否处于非阻塞模式。如果sctp代码不能立即获得锁，或者它只在套接字的缓冲区已满时阻塞，读操作是否会返回。
浏览 1提问于2013-03-23得票数 1
假设我有一个由n图像组成的交换链，并且我允许k“飞行中的帧”。我通过一组信号量imageAvailableSemaphore和renderFinishedSemaphore以及一个类似于在中完成的围栏imageInFlight来确保vkAcquireNextImageKHR、vkQueueSubmit和vkQueuePresentKHR之间的正确同步
imageAvailableSemaphores.resize(MAX_FRAMES_IN_FLIGHT);
renderFinishedSemaphores.resize(MAX_FRAMES_IN_FLIGHT);
inFli
浏览 0提问于2020-12-15得票数 2
背景I使用log4j2(2.12.1)和同步根和异步记录器。Lmax环缓冲区大小是默认的，为256*1024。我的附件在控制台里。我正在用JSON布局记录MapMessage。日志消息的平均大小约为100字节。
有了上面的细节，我注意到有几个线程在
"http-nio-8080-exec-172" #451
Thread State: BLOCKED (on object monitor) owned by "http-nio-8080-exec-148" Id=429
at org.apache.logging.log4j.core.appender
浏览 2提问于2020-05-04得票数 1
回答已采纳
1回答
循环队列显然更好，因为它帮助我们利用通过弹出元素而留下的空白空间。它还节省了可能用于在每次弹出后对元素进行横向移动的时间。
但是，有没有使用队列比使用循环队列更好的用例呢？
Queue =的定义我们将采用线性数组实现。遵循FIFO，无覆盖
循环队列的定义=环形缓冲区实现。遵循FIFO。无覆盖。
浏览 1提问于2016-11-01得票数 0
1回答
我有一个服务器和一个客户。客户机可以通过输入ADD:Joe:2来发送请求，比如ADD，它应该添加到list中。Key = Joe Value =2。
我试图在链接列表中添加一个键:value，该列表使用最大5个元素的缓冲区环。当链接列表达到元素(5)的最大大小并输入新键:value时，最古老的元素将被新元素覆盖。
每次我添加它似乎都很好，但是当达到最大值并尝试删除第一个键:VALUE时，它就崩溃了。
添加到列表中：
void push_item(struct item** Front,struct item** Rear,char *new_key,char *new_value,int n
浏览 3提问于2017-01-11得票数 0
2回答
无锁CAS混淆
、、、
嘿伙计们,
我正在读这些所谓的非阻塞技巧，但我没有什么疑问：
1)使用原子操作执行无锁操作，现在这些原子操作是什么？我的意思是，在一定程度上，他们也需要一个锁，对吗？那么，这种无锁的方法是否只为我们提供了更好的粒度锁定？
2)他们说非阻塞列表，现在非阻塞列表应该是什么:如果一个以上的线程在同一个插入时出现，那么只有一个线程会成功，另一个线程会做一些其他的工作，对吗?但是如果其他线程除了插入一个节点之外别无选择，那么为什么它是非阻塞的？它会不会被阻塞，直到上一次完成?？
3)在java中，它们是如何进行原子操作的？他们不是在做类似于synchronized boolean .....的事情吗?那
浏览 3提问于2011-05-13得票数 0
回答已采纳
5回答
循环缓冲区队列中的无锁进度保证
、、、、
有趣的是，我发现很多程序员错误地认为“无锁”仅仅意味着“没有互斥的并发编程”。通常，还有一个相关的误解，即编写无锁代码的目的是为了获得更好的并发性能。当然，无锁的正确定义实际上是关于进度保证的。无锁算法保证至少有一个线程能够向前推进，而不管其他线程在做什么。
这意味着没有锁的算法永远不会有一个线程依赖另一个线程来继续执行的代码。例如，无锁代码不能出现线程A设置标志的情况，然后线程B在等待线程A取消设置标志时继续循环。这样的代码基本上是实现了一个锁(或者我称之为伪装的互斥)。
然而，有些情况更微妙，有些情况下我真的无法判断算法是否符合无锁的条件，因为“取得进展”的概念有时对我来说是主观的。
其中
浏览 3提问于2017-08-27得票数 30
回答已采纳
我有两个C++进程，通过内存映射的单生产者单消费者(SPSC) 进行通信。进程只能在Linux/Intelx86-64上运行。语义是生产者填充前面的缓冲区，然后交换指针并更新计数器，让使用者知道它可以memcpy() back缓冲区。所有共享状态都存储在mmapped区域开始处的报头块中。
int _fd;
volatile char *_mappedBuffer;
...
_fd = shm_open("/dev/shm/ipc_buffer", O_CREAT | O_TRUNC | O_RDWR, S_IRUSR | S_IWUSR | S_IRGRP | S_IWG
浏览 2提问于2020-04-21得票数 4
回答已采纳
2回答
与核心音频线程同步
、、、、
我使用ioUnit的呈现回调将音频数据存储到循环缓冲区中：
OSStatus ioUnitRenderCallback(
void *inRefCon,
AudioUnitRenderActionFlags *ioActionFlags,
const AudioTimeStamp *inTimeStamp,
UInt32 inBusNumber,
浏览 3提问于2014-02-24得票数 0
回答已采纳
1回答
我正在设置一个记录器类，并希望优化日志记录。它必须是多色记录器，所以std::string::append(...)不是一种选择。 将新的log添加到字符串向量并不是一个好主意，因为每个push_back内存都会上升，fps会下降。我想创建包含string msg和color的Log结构和双缓冲区Log结构。写入第一个对象，然后将其传递给第二个Log对象并从中绘制，然后清除第一个Log对象...诸若此类。我试图实现它，但它并没有像我希望的那样工作。 在那一刻，我留下了对数的向量 class Logger
{
public:
struct Log {
std::str
浏览 16提问于2018-12-23得票数 1
回答已采纳
1回答
我一直在处理一个供应商的不可配置的应用程序，不幸的是，这是最完整的功能-在它的利基。我希望增加它的能力，在顶部的屏幕显示。它的数据访问非常可预测，允许我从查询模式中可靠地推断出我需要知道的信息，以便向用户提供与应用程序中的当前视图有关的其他相关信息。具体来说，它总是使用一个命名参数(定义用户正在查看的部分)执行TSQL语句(这是易于识别的部分)，这是我非常想得到的部分。
因此，简而言之，我希望创建一种机制：- Hook查询模式(通过通配符可以简单地表示)--提取命名的参数值--向(远程)覆盖应用程序发送一条带有参数值的消息
server是否有用于此任务的任何部分的功能？有什么更好的方法吗？(可
浏览 0提问于2012-01-18得票数 1
我是编程新手，以前只做过Python。我正在做一项关于使用多线程概念在Java中实现生产者-消费者问题的大学作业。在本例中，有两个生产者和一个消费者。生产者A以每5分钟一个的速率生产一个项目(仅是一个例子)，生产者B以每6分钟一个的速率生产一个项目。这些物品被放置在一个有限大小的货架上，只能容纳5件物品。 消费者每隔4分钟就会从货架上取下商品。当货架是空的时候，消费者将无法操作，而当货架已满时，生产者将无法操作。 该计划应该继续下去，直到每个生产者生产了10种商品，消费者消费了20种商品。 这就是我到目前为止所做的： class Buffer{
private int v;
private
浏览 30提问于2020-03-26得票数 1
2回答
实时数据的STFT /滑动FFT
、、、、
我最近接了一个项目，我需要对传入的麦克风数据执行实时滑动FFT分析。我选择的环境是OpenGL和Cinder，使用的是C++。
这是我第一次体验音频编程，我有点困惑。
这就是我要在OpenGL应用程序中实现的目标：
所以在每一帧中，都有一部分传入的数据。在for循环(因此多遍)中，将消耗当前数据的一个窗口，并对其执行FFT分析。对于For循环的下一次迭代，窗口将在数据中前进“跃点大小”，等等，直到到达数据的末尾。
现在这个过程必须是连续的。但正如你在上图中看到的，一旦我当前的应用程序帧结束，当下一个帧的数据进来时，我就不能从我离开前一帧的地方拿起(因为数据已经消失了)。你可以在图中看
浏览 6提问于2015-02-08得票数 1
5回答
基本上，我需要一个数据结构来存储服务器端的临时聊天消息。它应该是：
边界:因为我不需要存储太多的消息，所以客户机将每秒钟发送一次请求来获取新消息。我认为界限应该是最大的。在一秒钟内装入并发请求。当缓冲区已满时，将删除旧消息。
适用于高并发访问:我不想使用像Collections.synchronizedXXXX这样的数据结构，因为在迭代期间，如果其他线程改变了数据结构，例如添加了一条消息，它会抛出一个异常，所以我必须锁定整个数据结构，实际上我并不关心客户端请求是否能得到最后插入的消息，因为它们会在一秒钟后发送一个新请求，另一方面，写操作不应该被延迟。包java.util.concurr
浏览 9提问于2012-04-12得票数 8
回答已采纳
我有一个要求，两个并行运行的进程/程序(一个是用Python编写的，另一个是用C++编写的)需要获得独占访问，修改与硬件相关的值。
我试图使用flock实现它们之间的同步。
同样的代码如下，
Python代码
#!/usr/bin/python
import fcntl
import time
import datetime
import os
SLICE_SLEEP = 5
LOCK_HOLD_TIME = 20
TOTAL_WAIT_TIME = 300
class LockUtil(object):
FILE_PATH = "/tmp/sync.lock"
浏览 4提问于2020-06-22得票数 0
回答已采纳
2回答
在事件处理中，一个函数将值放入集合中，另一个函数从同一集合中删除值。项应该按照从源(套接字)接收到的顺序放在集合中，并以相同的方式读取，否则结果将会改变。
Queue是大多数人推荐的集合，但同时，当添加项目时，队列被阻塞，因此另一个函数必须等待，直到添加完成，这使得它效率低下，操作延迟随着时间的推移而增加。
例如，一个线程从队列读取，另一个线程写入同一队列。任一操作在队列上一次执行，直到它释放锁为止。有没有什么数据结构可以避免这种情况。
浏览 2提问于2016-10-15得票数 0
声明：
在返回主机访问指针之前，vkMapMemory不检查设备内存是否正在使用.应用程序必须确保以前提交的任何写入此范围的命令在主机读取或写入该范围之前已经完成，并且在主机写入该区域之前，从该区域读取的任何先前提交的命令都已完成。
它链接到，遗憾的是，它似乎还不存在。我想知道我会如何同步这个？
基本上我需要担心两件事
只有一个线程同时访问相同的范围。
Gpu目前并没有试图读取范围
我看到的唯一真正的同步方法是使用线程安全列表。每次您想要将/ read写入/从该缓冲区中读取时，您都必须添加当前试图将其读写到线程安全列表中的内存范围。
这意味着当您要访问该缓冲区时，需要锁
浏览 4提问于2016-08-09得票数 4
回答已采纳
我是一个多线程编程的初学者。
我一直在多线程环境中使用并发类，但突然间我对使用阻塞队列感到好奇。
我认为像ConcurrentHashMap这样的并发类使用锁定。
最近，我碰巧使用了队列，我查看了线程安全队列。所以我知道有BlockingQueue和linkedConcurrentQueue，我研究了这两个队列。
使用锁定，阻塞队列是线程安全的。这就是我想的典型的线程安全方式。
Concurrentqueue通过使用名为CAS的算法处理线程安全。但是，我不知道这个CAS的目标是队列本身还是属于队列的元素。即使多个线程同时轮询并发队列中的元素，它们是否轮询不同的元素？难道没有一种情况是一次投票同
浏览 2提问于2020-07-08得票数 0
回答已采纳
5回答
在Java语言中，有一个名为的类，我希望在.NET (C#)中找到类似的类。
我需要它的原因是，我需要查看集合中的最后一项，然后将集合中的第一项出队。
谢谢，AJ·拉文迪兰
浏览 0提问于2009-12-21得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
