zoukankan      html  css  js  c++  java
  • C+= concurrent_queue 线程安全测试

    更推荐使用:http://www.boost.org/doc/libs/1_56_0/doc/html/boost/lockfree/queue.html


    #include <include/tbb/tbb.h> #include <pthread.h> #include <iostream> using namespace std; #define NUM_THREAD 10 class person { public: person() { } person(int name, unsigned int thread_num){ this->name = name; this->thread_num = thread_num; } void print() { printf("%u %u ", thread_num, name); } private: int name; unsigned int thread_num; }; tbb::strict_ppl::concurrent_queue<person*> que; void* consumer(void* arg) { cout << arg << endl; while(true) { if(que.empty()) { cout << '.' << flush; sleep(1); } person* p; if(que.try_pop(p)) { p->print(); } } } void* producer(void* arg) { cout << arg << endl; unsigned int thread_num =(unsigned int)pthread_self(); for(int i=0; i<10; i++) { person* p = new person(i, thread_num); que.push(p); } } int main() { pthread_t tids_c[NUM_THREAD]; for(int i=0; i<NUM_THREAD; i++) { int ret = pthread_create(&tids_c[i], NULL, consumer, NULL); if(ret != 0) { cout << "start consumer failed" << endl; return -1; } } pthread_t tids[NUM_THREAD]; for(int i=0; i<NUM_THREAD; i++) { int ret = pthread_create(&tids[i], NULL, producer, NULL); if(ret != 0) { cout << "start produer failed" << endl; return -1; } } for(int i=0; i<NUM_THREAD; i++){ pthread_join(tids[i], NULL); pthread_join(tids_c[i], NULL); } cout << "exit" << endl; } /* vim: set ts=4 sw=4 sts=4 tw=100 */
    dic = {}
    with open('log.txt') as f:
        while True:
            line = f.readline()
            if not line:
                break;
            line = line.strip()
    
            arr = line.split('	')
            key = arr[1]
    
            if key not in dic:
                dic[key] = 1
            else:
                dic[key] += 1
    
        for key in dic:
            print key, dic[key]

  • 相关阅读:
    将博客搬至CSDN
    神州笔记本电脑【K670D】安装 Ubuntu18.04 系列操作
    ValueError: Unknown label type: 'continuous'
    Spark: JAVA_HOME is not set
    IDEA 搭建 Spark 源码 (Ubuntu)
    XX-Net 解决IPV6 不稳定,时好时坏。
    解决SBT下载慢,dump project structure from sbt?
    pip install kaggle 出现 【网络不可达】?
    Git clone 克隆Github上的仓库,速度慢?
    进程间的通信方式
  • 原文地址:https://www.cnblogs.com/i80386/p/4487441.html
Copyright © 2011-2022 走看看