注册 登录  
 加关注
   显示下一条  |  关闭
温馨提示!由于新浪微博认证机制调整,您的新浪微博帐号绑定已过期,请重新绑定!立即重新绑定新浪微博》  |  关闭

Code@Pig Home

喜欢背着一袋Code傻笑的Pig .. 忧美.欢笑.记忆.忘却 .之. 角落

 
 
 

日志

 
 

[ZeroMQ] "inproc://" performance  

2010-12-20 11:08:08|  分类: net_ZeroMQ |  标签: |举报 |字号 订阅

  下载LOFTER 我的照片书  |

对比了下 "inproc://" (lock-free queue) 与我原来写的 thr_queue,在线程间通讯的开销。
Amazing,在数据量很大的情况下,ZeroMQ 快很多。

测试代码:
--------------------------------------------------------------------------------
// zmqtest.c
#include "timer.h"
#include <zmq.h>
#include <unistd.h>
#include <stdio.h>
#include <pthread.h>

#define MSGCNT  (1024*1024)

void *thread_func(void *ctx)
{
        void *pair;
        zmq_msg_t msg;

        pair = zmq_socket(ctx, ZMQ_PAIR);
        zmq_connect(pair, "inproc://workers");

        while (1)
        {
                zmq_msg_init(&msg);
                zmq_recv(pair, &msg, 0);
                if ( *((int *)zmq_msg_data(&msg)) == MSGCNT )
                        break;
                zmq_msg_close(&msg);
        }

        tend();
        zmq_close(pair);

        printf("%f\n", tval());
        return (void *)0;
}

int main()
{
        pthread_t tid;
        zmq_msg_t msg;
        void *ctx, *pair;
        int i;

        ctx = zmq_init(0);
        pair = zmq_socket(ctx, ZMQ_PAIR);
        zmq_bind(pair, "inproc://workers");

        pthread_create(&tid, NULL, thread_func, ctx);

        tstart();
        for ( i = 1; i <= MSGCNT; i++ )
        {
                zmq_msg_init_size(&msg, sizeof(int));
                *((int *)zmq_msg_data(&msg)) = i;
                zmq_send(pair, &msg, 0);
                zmq_msg_close(&msg);
        }

        pthread_join(tid, NULL);

        zmq_close(pair);
        zmq_term(ctx);
        return 0;
}
--------------------------------------------------------------------------------
// thr.c
#include "thr_queue.h"
#include "timer.h"
#include <stdio.h>

#define MSGCNT  (1024*1024)

thr_queue_t workq;

void *thread_func(void *_)
{
        void *out;
        int n;
        while (1)
        {
                thr_queue_pop(&workq, &out);
                n = (int)out;
                if ( n == MSGCNT ) break;
        }

        tend();
        printf("%f\n", tval());

        return (void *)0;
}

int main()
{
        int i;
        pthread_t tid;

        thr_queue_create(&workq, MSGCNT);
        pthread_create(&tid, NULL, thread_func, NULL);

        tstart();
        for ( i = 1; i <= MSGCNT; i++ )
        {
                thr_queue_push(&workq, (void *)i);
        }

        pthread_join(tid, NULL);
        return 0;
}
--------------------------------------------------------------------------------
 zmqtest              thr
0.438140           12.378115
0.445820           11.966540
0.440500           12.958700
--------------------------------------------------------------------------------

线程间传递了 1024*1024 个 pointer。同一台硬件上,ZeroMQ快很多。
操作系统 FreeBSD 6.4 (libkse)、FreeBSD 8.1 (libthr) 都测试了下,结果一样。
看来 lock-free queue 的力量还是很强大滴。

运行过程中,zmqtest 每个线程的 cpu 占用都是 0%;而 thr 的线程 cpu 消耗大约在 67%。
  评论这张
 
阅读(3582)| 评论(1)
推荐 转载

历史上的今天

在LOFTER的更多文章

评论

<#--最新日志,群博日志--> <#--推荐日志--> <#--引用记录--> <#--博主推荐--> <#--随机阅读--> <#--首页推荐--> <#--历史上的今天--> <#--被推荐日志--> <#--上一篇,下一篇--> <#-- 热度 --> <#-- 网易新闻广告 --> <#--右边模块结构--> <#--评论模块结构--> <#--引用模块结构--> <#--博主发起的投票-->
 
 
 
 
 
 
 
 
 
 
 
 
 
 

页脚

网易公司版权所有 ©1997-2017