zoukankan      html  css  js  c++  java
  • boost::lockfree::queue

    #include <boost/thread/thread.hpp>
    #include <boost/lockfree/queue.hpp>
    #include <iostream>
    
    #include <boost/atomic.hpp>
    
    boost::atomic_int producer_count(0);
    boost::atomic_int consumer_count(0);
    
    boost::lockfree::queue<int> queue(128);//无锁的多生产者多消费者队列
    
    const int iterations = 10000;
    const int producer_thread_count = 4;
    const int consumer_thread_count = 4;
    
    void producer(void)
    {
        for (int i = 0; i != iterations; ++i) {
            int value = ++producer_count;
            while (!queue.push(value))
                ;
        }
    }
    
    boost::atomic<bool> done (false);
    void consumer(void)
    {
        int value;
        while (!done) {
            while (queue.pop(value))
                ++consumer_count;
        }
    
        while (queue.pop(value))
            ++consumer_count;
    }
    
    int main(int argc, char* argv[])
    {
        using namespace std;
        cout << "boost::lockfree::queue is ";
        if (!queue.is_lock_free())
            cout << "not ";
        cout << "lockfree" << endl;
    
        boost::thread_group producer_threads, consumer_threads;//线程组
    
        for (int i = 0; i != producer_thread_count; ++i)
            producer_threads.create_thread(producer);
    
        for (int i = 0; i != consumer_thread_count; ++i)
            consumer_threads.create_thread(consumer);
    
        producer_threads.join_all();
        done = true;
    
        consumer_threads.join_all();
    
        cout << "produced " << producer_count << " objects." << endl;
        cout << "consumed " << consumer_count << " objects." << endl;
        getchar();
    }
  • 相关阅读:
    python安装cnstd卡住
    _、__、__xx__之间的差别
    Celery模块使用
    同一主机,开启多个不同端口的redis进程
    php配置变更记录
    Linux安装Nodejs
    ElasticSearch中term和match探索
    Centos安装elasticsearch,php连接使用
    centos8自定义目录安装php7.3
    centos8自定义目录安装nginx
  • 原文地址:https://www.cnblogs.com/zzyoucan/p/3828566.html
Copyright © 2011-2022 走看看