标签: circular-buffer

我正在尝试使用 Boost 和 Interprocess 库在共享内存中创建循环缓冲区circular_buffer。我编译并运行了进程间文档中给出的示例，用于在共享内存中创建向量，没有任何问题。但是，当我修改它以使用 Boostcircular_buffer 时：

int main(int argc, char *argv[])
{
    managed_shared_memory segment(create_only, "MySharedMemory", 65536);
    const ShmemAllocator alloc_inst (segment.get_segment_manager());
    MyCircBuffer  *myCircBuf  = segment.construct<MyCircBuffer>("MyCircBuffer")(alloc_inst);
    return 0;
} 

我收到编译错误（由 引起segment.construct()）。知道我做错了什么吗？是否是因为circular_buffer不是 中列出的容器之一/boost/interprocess/containers，即它与 Interprocess 不兼容？

谢谢，

C

我想知道是否有可能有一个像增强循环缓冲区一样工作的地图。这意味着它的大小有限，当它达到有限大小时，它将开始覆盖第一个插入的元素。我也希望能够通过这样的缓冲区进行搜索并find or create使用[name]. 是否有可能创造这样的东西以及如何做到？

我已经阅读了许多关于数据包捕获/处理和主机堆栈的技术文档，试图了解这一切，但有一些地方让我感到困扰，希望有人能提供帮助。

假设您正在运行 tcpdump：在从 NIC 的环形缓冲区（物理 NIC 内存对吗？）复制数据包后，它会立即存储到 mbuf 中吗？然后 BPF从mbuf 中获取数据包的副本，然后将其存储在 BPF 缓冲区中，因此内存中同时存在两个副本？我试图了解确切的过程。

或者更像是：数据包同时从 NIC 复制到 mbuf（用于主机堆栈处理）和 BPF 伪同步？

一旦数据包通过 ip/tcp 输入函数通过主机堆栈处理，将 mbuf 作为位置（指向 mbuf），即数据包存储在 mbufs 中，如果数据包不是为系统寻址，例如通过集线器监控流量接收或 SPAN/Monitor 端口，数据包将被丢弃并且永远不会进入主机堆栈。

我似乎遇到过显示内核“盒子”中的 NIC 环形缓冲区（RX/TX）/将其与用户空间分开的图表，这让我再次猜测环形缓冲区是否实际分配的系统内存与物理内存不同网卡。

假设环形缓冲区是指 NIC 的物理内存，设备驱动程序确定 NIC 环形缓冲区的大小是否正确，将物理限制放在一边？例如，我可以通过修改驱动程序来缩小缓冲区吗？

谢谢！

我正在尝试为我的程序实现一个循环缓冲区。缓冲区用于在两个线程之间共享数据，如下所示。我使用 OpenCV 从相机（线程 1）抓取视频帧。然后我想将这些数据存储在一个循环缓冲区中，以便线程2可以从缓冲区中获取数据。

如何cv::Mat在 C++ 中为对象实现循环缓冲区？我知道如何为标准 C++ 对象（如int或char）创建循环缓冲区，但我无法使其与类型的对象一起使用cv::Mat。

有什么建议？

今天我看到了一些关于打结和循环数据结构的参考.我一直在读一些答案,解决方案似乎涉及使用ref指向列表的头部.一个特别的SO问题显示了一个Haskell示例,但我不知道Haskell是否足以知道该示例是否使用了与参数的Haskell等效.

有没有办法在不使用ref或类似构造的情况下使Clojure数据结构循环？

谢谢.

我有一个产生数据流的仪器；我的代码通过回调访问这些数据onDataAcquisitionEvent(const InstrumentOutput &data)。数据处理算法可能比数据到达的速度慢得多，所以我不能希望处理每一条数据（我没有必要），但希望处理尽可能多的数据。感谢该仪器作为环境传感器，其数据采集速率是我无法控制的。InstrumentOutput例如，可以是包含三个在不同位置同时进行的压力测量的类。

我还需要保留一些简短的数据历史记录。例如，假设我可以合理地希望每 200 毫秒左右处理一个数据样本。大多数情况下，我很乐意只处理最后一个样本，但有时我需要查看在最新样本之前到达的几秒钟的数据，这取决于最后一个样本中是否存在异常读数。

另一个要求是尽快退出onDataAcquisitionEvent()回调，以避免传感器中的数据丢失。

数据采集​​库（第三方）在单独的线程上采集仪器数据。

我想到了以下设计；具有单个生产者/单个消费者队列，并在 onDataAcquisitionEvent() 回调中将数据令牌推送到同步队列中。
在接收端，有一个循环从队列中弹出数据。由于数据到达率很高，循环几乎不会休眠。在每次迭代中，会发生以下情况：

1. 从队列中弹出所有可用数据，
2. 弹出的数据被复制到一个循环缓冲区中（我使用了 boost 循环缓冲区），这样一些历史总是可用的，
3. 处理缓冲区中的最后一个元素（并可能查看之前的元素），
4. 重复循环。

问题：

1. 这个设计合理吗，有什么陷阱？和
2. 什么是更好的设计？

编辑：我想到的一个问题是，当循环缓冲区的大小不足以容纳所需的历史记录时；目前我只是重新分配循环缓冲区，将其大小加倍。我希望我只需要这样做一两次。

我有一个类，它使用互斥锁和两个用于同步的条件变量来实现线程化的生产者/消费者系统。当有项目要使用时，生产者向消费者线程发送信号，消费者在消费完项目时向生产者线程发送信号。线程继续生产和消费，直到析构函数通过设置布尔变量请求它们退出。因为其中一个线程可能正在等待一个条件变量，所以我不得不对quit变量进行第二次检查，感觉不对，很乱……

我已将问题简化为以下示例（使用 g++4.7 在 GNU/Linux 上工作）示例：

// C++11and Boost required.
#include <cstdlib> // std::rand()
#include <cassert>

#include <boost/circular_buffer.hpp>

#include <atomic>
#include <chrono>
#include <condition_variable>
#include <iostream>
#include <mutex>
#include <thread>
#include <vector>

// Creates a single producer and single consumer thread.
class prosumer
{
    public:
        // Create the circular buffer and start the producer and consumer thread.
        prosumer()
            : quit_{ false }
            , buffer_{ circular_buffer_capacity }
            , producer_{ &prosumer::producer_func, this }
            , consumer_{ &prosumer::consumer_func, this }
        {}

        // Set the …

我正在为STM32F3 mc(STM32F3-Discovery)编写嵌入式代码.我需要输出一些数据,UART和我的使用DMA此,因为这可以让我专注于传感器读取和数据处理,而不是等待字节传输完成.然而问题是我必须结合:

1. 格式化输出(即来自printf的一些)
2. 连续多次打印(在上一次打印完成之前发生)

所以我在想循环缓冲区.但我不认为我知道如何使sprintf尊重缓冲区的结束并继续写入缓冲区的开头.我当然可以创建另一个临时缓冲区,在那里打印,并逐字节复制,但它对我来说并不优雅.

我正在考虑实现一个无锁的圆形数组.一个问题是以无锁的方式保持头部和尾部指针.我想到的代码是:

int circularIncrementAndGet(AtomicInteger i) {
    i.compareAndSet(array.length - 1, -1);
    return i.incrementAndGet();
}

然后我会做类似的事情:

void add(double value) {
    int idx = circularIncrementAndGet(tail);
    array[idx] = value;
}

(注意,如果数组是完整的旧值将被覆盖,我很好).

有没有人发现这个设计有问题？我怀疑可能存在我没有看到的竞争状况.

我正在尝试为作业实现一个循环缓冲区。为了节省时间，我想在重新排序缓冲区类中使用双端队列。这是我第一次尝试编写一个包含双端队列的类。

#ifndef ROB_H_
#define ROB_H_

#include <deque>
#include <cstdio>

using namespace std;

class ReorderBuffer{
    public:
        ReorderBuffer (int size);
        void doStuff();

        std::deque<int> buffer;
};    

ReorderBuffer::ReorderBuffer (int size){
    std::deque<int> buffer(size);
}

void ReorderBuffer::doStuff(){

    std::deque<int> buffer(4);

    buffer.push_back(5);
    buffer.push_front(2);
    buffer.push_back(3);
    buffer.push_back(4);
    printf("%d %d\n",buffer.at(0),buffer.pop_front());

}


#endif

在 main 中，我创建了一个大小为 4 的重新排序缓冲区并调用 doStuff()。当我尝试编译时，它说无效使用 void 表达式。我已将错误范围缩小到我对 buffer.pop_front() 的调用。为什么它会抱怨，在我的班级中放置双端队列的最佳方法是什么？谢谢！