GitHub - cameron314/concurrentqueue: A fast multi-producer, multi-consumer lock-free concurrent queue for C++11

公司主营业务：成都网站设计、成都做网站、移动网站开发等业务。帮助企业客户真正实现互联网宣传，提高企业的竞争能力。成都创新互联是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化，感谢他们对我们的高要求，感谢他们从不同领域给我们带来的挑战，让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。成都创新互联推出金水免费做网站回馈大家。

提供了一个无锁队列。它的实现基于原子操作CAS，比大多数其它队列性能更强，而且使用更方便。本文的性能测试方法基于文章《C++计算打印函数和代码块的执行时间（支持所有类型函数）》，下面用例子讲解该队列的使用，以及跟STL队列容器queue的性能对比。

假设我们想要实现一个最简单的生产者消费者模式。生产者线程负责把数据入队列，消费者线程把数据出队列，为了保护临界资源，我们得加互斥锁。为了在队列为空的时候阻止消费者继续消费，还得加条件变量。所以用C++11的语法和容器std::queue实现的代码如下：

#include#include#include#include#include#include#includeusing namespace std;
#define TOTAL 1000000

std::mutex m;
std::condition_variable cv;
queuegQueue;


templateauto measure(T&& func, Args&&... args)->std::future::type>{
    using return_type = typename std::result_of::type;
    auto task = std::make_shared>(std::bind(std::forward(func), std::forward(args)...));
    std::futureres = task->get_future();
    auto begin = std::chrono::high_resolution_clock::now();
    (*task)();
    auto end = std::chrono::high_resolution_clock::now();
    auto elapsed = std::chrono::duration_cast(end - begin);
    printf("执行时间: % .3f seconds.\n", elapsed.count() * 1e-9);
    return res;
}


void producer_thread()
{
    for (int i = 0; i< TOTAL; i++)
    {
        std::unique_locklk(m);
        gQueue.push(i);
        cv.notify_one();
    }
}

void consumer_thread()
{
    int element = 0;
    while (element != TOTAL -1)
    {
        std::unique_locklk(m);
        cv.wait(lk, [] {return !gQueue.empty(); });
        element = gQueue.front();
        gQueue.pop();
        printf("element:%d\n", element);
    }
}

int main()
{
    measure([] {
        thread a(producer_thread);
        thread b(consumer_thread);
        a.join();
        b.join();
        });

    return 0;
}

运行效果如下，可以看到总执行时间为19.632秒。

我们把队列改为使用concurrentqueue，代码如下：

#include#include#include#include#include#include#include "blockingconcurrentqueue.h"

using namespace std;
#define TOTAL 1000000

moodycamel::BlockingConcurrentQueuegConcurrentQueue;


templateauto measure(T&& func, Args&&... args)->std::future::type>{
    using return_type = typename std::result_of::type;
    auto task = std::make_shared>(std::bind(std::forward(func), std::forward(args)...));
    std::futureres = task->get_future();
    auto begin = std::chrono::high_resolution_clock::now();
    (*task)();
    auto end = std::chrono::high_resolution_clock::now();
    auto elapsed = std::chrono::duration_cast(end - begin);
    printf("执行时间: % .3f seconds.\n", elapsed.count() * 1e-9);
    return res;
}


void producer_thread()
{
    for (int i = 0; i< TOTAL; i++)
    {
        gConcurrentQueue.enqueue(i);
    }
}

void consumer_thread()
{
    int element = 0;
    while (element != TOTAL -1)
    {
        gConcurrentQueue.wait_dequeue(element);
        printf("element:%d\n", element);
    }
}

int main()
{
    measure([] {
        thread a(producer_thread);
        thread b(consumer_thread);
        a.join();
        b.join();
        });

    return 0;
}

运行效果如下，可以看到总执行时间为18.198秒。

由上面的例子可以看出，实现相同的功能，使用concurrentqueue比std::queue性能还要略强一点。而且concurrentqueue接口完善，封装程度更高，使用它后我们不需要再在代码中显式增加互斥锁和条件变量来进行同步了，使用更简单，可以使我们的代码可读性更好。

你是否还在寻找稳定的海外服务器提供商？创新互联www.cdcxhl.cn海外机房具备T级流量清洗系统配攻击溯源，准确流量调度确保服务器高可用性，企业级服务器适合批量采购，新人活动首月15元起，快前往官网查看详情吧

文章名称：C++无锁队列concurrentqueue的使用和性能速度测试-创新互联
网站地址：http://lswzjz.com/article/diijgc.html